@@ -36,14 +36,14 @@ |
||
| 36 | 36 | |
| 37 | 37 | $connector($this->wssHost, [$this->subProtocol], ['Host' => $this->host] + $this->auth->getBasicAuth())->then( |
| 38 | 38 | |
| 39 | - function (WebSocket $stream) { |
|
| 40 | - $stream->on('message', function (MessageInterface $message) { |
|
| 39 | + function(WebSocket $stream) { |
|
| 40 | + $stream->on('message', function(MessageInterface $message) { |
|
| 41 | 41 | $this->events->message($message, $this->apiWrapper, $this->gearmanClient); |
| 42 | 42 | }); |
| 43 | - $stream->on('close', function ($code = null, $reason = null) { |
|
| 43 | + $stream->on('close', function($code = null, $reason = null) { |
|
| 44 | 44 | $this->events->close($code, $reason); |
| 45 | 45 | }); |
| 46 | - }, function (\Exception $e) use ($loop) { |
|
| 46 | + }, function(\Exception $e) use ($loop) { |
|
| 47 | 47 | $this->events->error($e); |
| 48 | 48 | $loop->stop(); |
| 49 | 49 | } |
@@ -14,7 +14,7 @@ |
||
| 14 | 14 | |
| 15 | 15 | public function close($code, $reason) |
| 16 | 16 | { |
| 17 | - echo "Connection closed. ({$code}){$reason}" . PHP_EOL; |
|
| 17 | + echo "Connection closed. ({$code}){$reason}".PHP_EOL; |
|
| 18 | 18 | } |
| 19 | 19 | |
| 20 | 20 | public function error(\Exception $exception) |