comodojo / daemon

        $datagram = '';

        $socket = $connection->getSocket();

        while (true) {

            $recv = @socket_read($socket, $this->read_buffer, PHP_NORMAL_READ);

            // if ( $recv === false ) break;

            // if ( $recv === 0 ) return null;

            if ( $recv === false ) return null;

            $datagram .= $recv;

            if (empty($recv) || strstr($recv, PHP_EOL)) break;

        }

        $datagram = trim($datagram);

        $datagram = '';

        while (true) {

            $recv = @socket_read($this->socket, $this->read_buffer, PHP_NORMAL_READ);

            if ( $recv === false ) break;

            if ( $recv === 0 ) return null;

            $datagram .= $recv;

            if(strstr($recv, PHP_EOL)) break;

        }

        return trim($datagram);