@@ 169-181 (lines=13) @@ | ||
166 | GlobalState::incr('streams.read.ticks'); |
|
167 | GlobalState::incr('streams.total.ticks'); |
|
168 | }); |
|
169 | $loop->on('removeReadStream', function ($stream) { |
|
170 | $key = (int) $stream; |
|
171 | ||
172 | if (isset($this->streamsRead[$key])) { |
|
173 | unset($this->streamsRead[$key]); |
|
174 | } |
|
175 | if (isset($this->streamsDuplex[$key]) && !isset($this->streamsWrite[$key])) { |
|
176 | unset($this->streamsDuplex[$key]); |
|
177 | } |
|
178 | ||
179 | GlobalState::set('streams.read.current', count($this->streamsRead)); |
|
180 | GlobalState::set('streams.total.current', count($this->streamsDuplex)); |
|
181 | }); |
|
182 | ||
183 | $loop->on('addWriteStream', function ($stream) { |
|
184 | $key = (int) $stream; |
|
@@ 201-213 (lines=13) @@ | ||
198 | GlobalState::incr('streams.write.ticks'); |
|
199 | GlobalState::incr('streams.total.ticks'); |
|
200 | }); |
|
201 | $loop->on('removeWriteStream', function ($stream) { |
|
202 | $key = (int) $stream; |
|
203 | ||
204 | if (isset($this->streamsWrite[$key])) { |
|
205 | unset($this->streamsWrite[$key]); |
|
206 | } |
|
207 | if (isset($this->streamsDuplex[$key]) && !isset($this->streamsRead[$key])) { |
|
208 | unset($this->streamsDuplex[$key]); |
|
209 | } |
|
210 | ||
211 | GlobalState::set('streams.write.current', count($this->streamsWrite)); |
|
212 | GlobalState::set('streams.total.current', count($this->streamsDuplex)); |
|
213 | }); |
|
214 | ||
215 | $loop->on('removeStream', function ($stream) { |
|
216 | $key = (int) $stream; |