Code Duplication    Length = 13-13 lines in 2 locations

src/InfoProvider.php 2 locations

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