@@ -40,18 +40,18 @@ |
||
40 | 40 | */ |
41 | 41 | public function execute(): void |
42 | 42 | { |
43 | - $this->worker->onWorkerStart = function () { |
|
43 | + $this->worker->onWorkerStart = function() { |
|
44 | 44 | |
45 | 45 | $connection = new AsyncTcpConnection($this->hostStream . static::CHANNEL_TYPE . "/" . static::CHANNEL_ACCESS . "/v3"); |
46 | 46 | |
47 | 47 | $connection->transport = 'ssl'; |
48 | - $connection->onConnect = function ($connection) { |
|
48 | + $connection->onConnect = function($connection) { |
|
49 | 49 | $connection->send(json_encode(["op" => $this->operation, "args" => $this->topic])); |
50 | 50 | }; |
51 | 51 | |
52 | 52 | $callback = $this->callback; |
53 | 53 | |
54 | - $connection->onMessage = function ($connection, $message) use ($callback) { |
|
54 | + $connection->onMessage = function($connection, $message) use ($callback) { |
|
55 | 55 | |
56 | 56 | $message = json_decode($message, true); |
57 | 57 |