WyriHaximus / reactphp-event-loop-inspector

    protected function setupStreams(LoopDecorator $loop)

    {

        $loop->on('addReadStream', function ($stream) {

            $key = (int) $stream;

            $this->streamsRead[$key] = $stream;

            $this->streamsDuplex[$key] = $stream;

            GlobalState::set('streams.read.current', count($this->streamsRead));

            GlobalState::set('streams.total.current', count($this->streamsDuplex));

            GlobalState::incr('streams.read.total');

            if (!isset($this->streamsWrite[$key])) {

                GlobalState::incr('streams.total.total');

            }

        });

        $loop->on('readStreamTick', function () {

            GlobalState::incr('streams.read.ticks');

            GlobalState::incr('streams.total.ticks');

            GlobalState::set('streams.total.current', count($this->streamsDuplex));

        });

        $loop->on('addWriteStream', function ($stream) {

            $key = (int) $stream;

            $this->streamsWrite[$key] = $stream;

            $this->streamsDuplex[$key] = $stream;

            GlobalState::set('streams.write.current', count($this->streamsWrite));

            GlobalState::set('streams.total.current', count($this->streamsDuplex));

            GlobalState::incr('streams.write.total');

            if (!isset($this->streamsRead[$key])) {

                GlobalState::incr('streams.total.total');

            }

        });

        $loop->on('writeStreamTick', function () {

            GlobalState::incr('streams.write.ticks');

            GlobalState::incr('streams.total.ticks');