@@ -42,16 +42,16 @@ |
||
42 | 42 | */ |
43 | 43 | public function execute(): void |
44 | 44 | { |
45 | - $this->worker->onWorkerStart = function () { |
|
46 | - $connection = new AsyncTcpConnection($this->hostStream.'/'.self::CHANNEL_ACCESS.'/'.$this->streamType); |
|
45 | + $this->worker->onWorkerStart = function() { |
|
46 | + $connection = new AsyncTcpConnection($this->hostStream . '/' . self::CHANNEL_ACCESS . '/' . $this->streamType); |
|
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 | $message = json_decode($message, true); |
56 | 56 | |
57 | 57 | // Default DTO |
@@ -15,7 +15,7 @@ |
||
15 | 15 | */ |
16 | 16 | public static function assign($value, $defaultValue = null) |
17 | 17 | { |
18 | - return (string) $value ?? $defaultValue; |
|
18 | + return (string)$value ?? $defaultValue; |
|
19 | 19 | } |
20 | 20 | |
21 | 21 | /** |
@@ -38,6 +38,6 @@ |
||
38 | 38 | |
39 | 39 | public function assign($value, $defaultValue = 0): int |
40 | 40 | { |
41 | - return (int) $value ?? $defaultValue; |
|
41 | + return (int)$value ?? $defaultValue; |
|
42 | 42 | } |
43 | 43 | } |