@@ -130,7 +130,7 @@ discard block |
||
130 | 130 | $promise->done(function() use ($stack) { |
131 | 131 | $this->logger->info('-- Starting to listen... --'); |
132 | 132 | |
133 | - $this->listener = function (Message $message) use ($stack) { |
|
133 | + $this->listener = function(Message $message) use ($stack) { |
|
134 | 134 | if (!$this->connected) { |
135 | 135 | // After we disconnect stop listening. |
136 | 136 | return false; |
@@ -246,7 +246,7 @@ discard block |
||
246 | 246 | $listener = null; |
247 | 247 | |
248 | 248 | // Listen for a reply |
249 | - $listener = function (Message $message) use ($deferred, $currentId, &$listener) { |
|
249 | + $listener = function(Message $message) use ($deferred, $currentId, &$listener) { |
|
250 | 250 | $payload = json_decode($message->getPayload(), true); |
251 | 251 | $replyTo = $payload['reply_to'] ?? 0; |
252 | 252 | |
@@ -331,7 +331,7 @@ discard block |
||
331 | 331 | // Manage connecting |
332 | 332 | $connection = websocketConnect($rtmPayload->getUrl(), [], [], $loop); |
333 | 333 | $connection->then( |
334 | - function (WebSocket $connection) use ($deferred, $rtmPayload) { |
|
334 | + function(WebSocket $connection) use ($deferred, $rtmPayload) { |
|
335 | 335 | $this->connected($connection, $rtmPayload); |
336 | 336 | $deferred->resolve([$connection, $rtmPayload]); |
337 | 337 |