@@ -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 | } |