@@ 193-205 (lines=13) @@ | ||
190 | GlobalState::incr('streams.read.ticks'); |
|
191 | GlobalState::incr('streams.total.ticks'); |
|
192 | }); |
|
193 | $loop->on('removeReadStream', function ($stream) { |
|
194 | $key = (int) $stream; |
|
195 | ||
196 | if (isset($this->streamsRead[$key])) { |
|
197 | unset($this->streamsRead[$key]); |
|
198 | } |
|
199 | if (isset($this->streamsDuplex[$key]) && !isset($this->streamsWrite[$key])) { |
|
200 | unset($this->streamsDuplex[$key]); |
|
201 | } |
|
202 | ||
203 | GlobalState::set('streams.read.current', count($this->streamsRead)); |
|
204 | GlobalState::set('streams.total.current', count($this->streamsDuplex)); |
|
205 | }); |
|
206 | ||
207 | $loop->on('addWriteStream', function ($stream) { |
|
208 | $key = (int) $stream; |
|
@@ 225-237 (lines=13) @@ | ||
222 | GlobalState::incr('streams.write.ticks'); |
|
223 | GlobalState::incr('streams.total.ticks'); |
|
224 | }); |
|
225 | $loop->on('removeWriteStream', function ($stream) { |
|
226 | $key = (int) $stream; |
|
227 | ||
228 | if (isset($this->streamsWrite[$key])) { |
|
229 | unset($this->streamsWrite[$key]); |
|
230 | } |
|
231 | if (isset($this->streamsDuplex[$key]) && !isset($this->streamsRead[$key])) { |
|
232 | unset($this->streamsDuplex[$key]); |
|
233 | } |
|
234 | ||
235 | GlobalState::set('streams.write.current', count($this->streamsWrite)); |
|
236 | GlobalState::set('streams.total.current', count($this->streamsDuplex)); |
|
237 | }); |
|
238 | ||
239 | $loop->on('removeStream', function ($stream) { |
|
240 | $key = (int) $stream; |