private function processConnectionPool(): void
    {
        $readableConnections = $this->connectionPool->getReadableConnections(5);

        foreach ($readableConnections as $id => $connection) {
            if (!isset($this->connectionHandlers[$id])) {
                $this->connectionHandlers[$id] = $this->connectionHandlerFactory->createConnectionHandler($this->kernel, $connection);
            }

            try {
                $statusCodes = $this->connectionHandlers[$id]->ready();
                $this->considerStatusCodes($statusCodes);
            } catch (UserlandDaemonException $exception) {
                $this->daemonOptions->getOption(DaemonOptions::LOGGER)->error($exception->getMessage());
            }

            if ($this->connectionHandlers[$id]->isClosed()) {
                unset($this->connectionHandlers[$id]);
            }
        }
    }
private function processConnectionPool(): void
    {
        $readableConnections = $this->connectionPool->getReadableConnections(5);

        foreach ($readableConnections as $id => $connection) {
            if (!isset($this->connectionHandlers[$id])) {
                $this->connectionHandlers[$id] = $this->connectionHandlerFactory->createConnectionHandler($this->kernel, $connection);
            }

            try {
                $statusCodes = $this->connectionHandlers[$id]->ready();
                $this->considerStatusCodes($statusCodes);
            } catch (UserlandDaemonException $exception) {
                $this->daemonOptions->getOption(DaemonOptions::LOGGER)->error($exception->getMessage());
            }

            if ($this->connectionHandlers[$id]->isClosed()) {
                unset($this->connectionHandlers[$id]);
            }
        }
    }
private function processConnectionPool ( ) : void { $ readableConnections = $ this -> connectionPool -> getReadableConnections ( 5 ) ; foreach ( $ readableConnections as $ id => $ connection ) { if ( ! isset ( $ this -> connectionHandlers [ $ id ] ) ) { $ this -> connectionHandlers [ $ id ] = $ this -> connectionHandlerFactory -> createConnectionHandler ( $ this -> kernel , $ connection ) ; } try { $ statusCodes = $ this -> connectionHandlers [ $ id ] -> ready ( ) ; $ this -> considerStatusCodes ( $ statusCodes ) ; } catch ( UserlandDaemonException $ exception ) { $ this -> daemonOptions -> getOption ( DaemonOptions :: LOGGER ) -> error ( $ exception -> getMessage ( ) ) ; } if ( $ this -> connectionHandlers [ $ id ] -> isClosed ( ) ) { unset ( $ this -> connectionHandlers [ $ id ] ) ; } } }
Wait for connections in the pool to become readable. Create connection
handlers for new connections and trigger the ready method when there is
data for the handlers to receive. Clean up closed connections.

@throws \Exception
Wait for connections in the pool to become readable . Create connection handlers for new connections and trigger the ready method when there is data for the handlers to receive . Clean up closed connections .