@@ -80,14 +80,14 @@ |
||
| 80 | 80 | $this->endpoint = $endpoint; |
| 81 | 81 | |
| 82 | 82 | $this->events = (new Events()) |
| 83 | - ->attach(Events\Socket::CONNECTED, function () { |
|
| 83 | + ->attach(Events\Socket::CONNECTED, function() { |
|
| 84 | 84 | $this->connected(); |
| 85 | 85 | }) |
| 86 | - ->attach(Events\Socket::CLOSED, function () { |
|
| 86 | + ->attach(Events\Socket::CLOSED, function() { |
|
| 87 | 87 | $this->connecting(); |
| 88 | 88 | }) |
| 89 | - ->attach(Events\Socket::ERROR, function () { |
|
| 90 | - Timer::after(self::RETRY_WAIT, function () { |
|
| 89 | + ->attach(Events\Socket::ERROR, function() { |
|
| 90 | + Timer::after(self::RETRY_WAIT, function() { |
|
| 91 | 91 | $this->connecting(); |
| 92 | 92 | }); |
| 93 | 93 | }) |
@@ -54,7 +54,7 @@ discard block |
||
| 54 | 54 | $this->cmg = $cmg; |
| 55 | 55 | $this->recv = $recv; |
| 56 | 56 | |
| 57 | - $this->pipe = $cmg->hosting($recv, static function (Address $recv) { |
|
| 57 | + $this->pipe = $cmg->hosting($recv, static function(Address $recv) { |
|
| 58 | 58 | return new TCP($recv); |
| 59 | 59 | }); |
| 60 | 60 | } |
@@ -76,7 +76,7 @@ discard block |
||
| 76 | 76 | { |
| 77 | 77 | $buf = ''; |
| 78 | 78 | |
| 79 | - $node = $this->env->app() . (($t = $this->env->tagged()) ? sprintf(':%s', $t) : ''); |
|
| 79 | + $node = $this->env->app().(($t = $this->env->tagged()) ? sprintf(':%s', $t) : ''); |
|
| 80 | 80 | $stream = $scene; |
| 81 | 81 | |
| 82 | 82 | if (!isset($this->assets[$node][$stream])) { |