Innmind /
AMQP
| @@ 180-193 (lines=14) @@ | ||
| 177 | ); |
|
| 178 | } |
|
| 179 | ||
| 180 | private function arguments(MapInterface $arguments): Table |
|
| 181 | { |
|
| 182 | return new Table( |
|
| 183 | $arguments->reduce( |
|
| 184 | new Map('string', Value::class), |
|
| 185 | function(Map $carry, string $key, $value): Map { |
|
| 186 | return $carry->put( |
|
| 187 | $key, |
|
| 188 | ($this->translate)($value) |
|
| 189 | ); |
|
| 190 | } |
|
| 191 | ) |
|
| 192 | ); |
|
| 193 | } |
|
| 194 | ||
| 195 | private function serializeProperties(Message $message): array |
|
| 196 | { |
|
| @@ 119-132 (lines=14) @@ | ||
| 116 | /** |
|
| 117 | * @param MapInterface<string, mixed> $arguments |
|
| 118 | */ |
|
| 119 | private function translate(MapInterface $arguments): Table |
|
| 120 | { |
|
| 121 | return new Table( |
|
| 122 | $arguments->reduce( |
|
| 123 | new Map('string', Value::class), |
|
| 124 | function(Map $carry, string $key, $value): Map { |
|
| 125 | return $carry->put( |
|
| 126 | $key, |
|
| 127 | ($this->translate)($value) |
|
| 128 | ); |
|
| 129 | } |
|
| 130 | ) |
|
| 131 | ); |
|
| 132 | } |
|
| 133 | } |
|
| 134 | ||
