@@ -35,14 +35,14 @@ |
||
35 | 35 | |
36 | 36 | $connector($this->wssHost, [$this->subProtocol], ['Host' => $this->host] + $this->auth->getBasicAuth())->then( |
37 | 37 | |
38 | - function (WebSocket $stream) use ($gearman, $apiWrapper) { |
|
38 | + function(WebSocket $stream) use ($gearman, $apiWrapper) { |
|
39 | 39 | |
40 | - $stream->on('message', function (MessageInterface $msg) use ($gearman, $apiWrapper) { |
|
40 | + $stream->on('message', function(MessageInterface $msg) use ($gearman, $apiWrapper) { |
|
41 | 41 | $result = $apiWrapper->getApiCallbackMethod($msg); |
42 | 42 | $gearman->doHighBackground($result->getMethodName(), $msg); |
43 | 43 | }); |
44 | 44 | |
45 | - }, function (\Exception $e) use ($loop) { |
|
45 | + }, function(\Exception $e) use ($loop) { |
|
46 | 46 | echo "Could not connect: {$e->getMessage()}\n"; |
47 | 47 | $loop->stop(); |
48 | 48 | } |