@@ -67,12 +67,12 @@ discard block |
||
67 | 67 | $this->program = $program; |
68 | 68 | $this->failure = $failure; |
69 | 69 | |
70 | - $this->processor = function ($data, Context $ctx = null) { |
|
70 | + $this->processor = function($data, Context $ctx = null) { |
|
71 | 71 | async($this->program, $ctx ?? new Context(), $data)->then($this->done, $this->done); |
72 | 72 | }; |
73 | 73 | |
74 | - $this->done = function ($e = null) { |
|
75 | - $this->running --; |
|
74 | + $this->done = function($e = null) { |
|
75 | + $this->running--; |
|
76 | 76 | |
77 | 77 | if ($this->failure && $e instanceof Throwable) { |
78 | 78 | ($this->failure)($e); |
@@ -81,7 +81,7 @@ discard block |
||
81 | 81 | $this->execute(); |
82 | 82 | }; |
83 | 83 | |
84 | - $this->close = function () { |
|
84 | + $this->close = function() { |
|
85 | 85 | $this->closing = true; |
86 | 86 | }; |
87 | 87 | |
@@ -105,7 +105,7 @@ discard block |
||
105 | 105 | return; |
106 | 106 | } |
107 | 107 | |
108 | - $this->running ++; |
|
108 | + $this->running++; |
|
109 | 109 | |
110 | 110 | ($recv = $this->chan->recv())->then($this->processor, $this->close); |
111 | 111 |