@@ -100,7 +100,7 @@ discard block |
||
| 100 | 100 | |
| 101 | 101 | array_walk_recursive( |
| 102 | 102 | $data, |
| 103 | - function (&$value, $key) { |
|
| 103 | + function(&$value, $key) { |
|
| 104 | 104 | if (is_object($value)) { |
| 105 | 105 | throw new \RuntimeException( |
| 106 | 106 | sprintf('The object "%s" in key "%s" can\'t be part of publish data, only scalar values can be sent.', get_class($value), $key) |
@@ -121,7 +121,7 @@ discard block |
||
| 121 | 121 | $channels = array_keys($this->registry->getEndpoint()->getSubscriptionsResolvers()); |
| 122 | 122 | $this->pubSubHandler->consume( |
| 123 | 123 | $channels, |
| 124 | - function (SubscriptionMessage $message) use ($output, $debug) { |
|
| 124 | + function(SubscriptionMessage $message) use ($output, $debug) { |
|
| 125 | 125 | /** @var Request $request */ |
| 126 | 126 | $request = $message->getMeta()['request'] ?? null; |
| 127 | 127 | $subscribedFilters = $message->getMeta()['arguments'] ?? []; |
@@ -169,7 +169,7 @@ discard block |
||
| 169 | 169 | { |
| 170 | 170 | array_walk_recursive( |
| 171 | 171 | $data, |
| 172 | - function (&$value) { |
|
| 172 | + function(&$value) { |
|
| 173 | 173 | if ($value instanceof NodeInterface) { |
| 174 | 174 | $value = IDEncoder::encode($value); |
| 175 | 175 | } |