|
@@ -130,7 +130,7 @@ discard block |
|
|
block discarded – undo |
|
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 |
|
|
block discarded – undo |
|
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 |
|
|
block discarded – undo |
|
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
|
|
Please login to merge, or discard this patch.