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