Skip to content
This repository was archived by the owner on Oct 30, 2024. It is now read-only.

Commit d66f3ab

Browse files
committed
Added yaml encoder class
1 parent d2e9df4 commit d66f3ab

1 file changed

Lines changed: 40 additions & 0 deletions

File tree

src/Nats/Encoders/YAMLEncoder.php

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
1+
<?php
2+
namespace Nats\Encoders;
3+
4+
/**
5+
* Class YAMLEncoder
6+
*
7+
* Encodes and decodes messages in YAML format.
8+
*
9+
* @package Nats
10+
*/
11+
class YAMLEncoder implements Encoder
12+
{
13+
14+
15+
/**
16+
* Encodes a message to YAML.
17+
*
18+
* @param string $payload Message to decode.
19+
*
20+
* @return mixed
21+
*/
22+
public function encode($payload)
23+
{
24+
$payload = yaml_emit($payload);
25+
return $payload;
26+
}
27+
28+
/**
29+
* Decodes a message from YAML.
30+
*
31+
* @param string $payload Message to decode.
32+
*
33+
* @return mixed
34+
*/
35+
public function decode($payload)
36+
{
37+
$payload = yaml_parse($payload);
38+
return $payload;
39+
}
40+
}

0 commit comments

Comments
 (0)