| 
                                
                                    @@ 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;  |