@@ -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])) { |