src/PAMI/Client/Impl/ClientImpl.php
protected function getMessages()
    {
        $msgs = array();
        // Read something.
        $read = @fread($this->socket, 65535);
        if ($read === false || @feof($this->socket)) {
            throw new ClientException('Error reading');
        }
        $this->currentProcessingMessage .= $read;
        // If we have a complete message, then return it. Save the rest for
        // later.
        while (($marker = strpos($this->currentProcessingMessage, Message::EOM))) {
            $msg = substr($this->currentProcessingMessage, 0, $marker);
            $this->currentProcessingMessage = substr(
                $this->currentProcessingMessage,
                $marker + strlen(Message::EOM)
            );
            $msgs[] = $msg;
        }
        return $msgs;
    }
protected function getMessages()
    {
        $msgs = array();
        // Read something.
        $read = @fread($this->socket, 65535);
        if ($read === false || @feof($this->socket)) {
            throw new ClientException('Error reading');
        }
        $this->currentProcessingMessage .= $read;
        // If we have a complete message, then return it. Save the rest for
        // later.
        while (($marker = strpos($this->currentProcessingMessage, Message::EOM))) {
            $msg = substr($this->currentProcessingMessage, 0, $marker);
            $this->currentProcessingMessage = substr(
                $this->currentProcessingMessage,
                $marker + strlen(Message::EOM)
            );
            $msgs[] = $msg;
        }
        return $msgs;
    }
protected function getMessages ( ) { $ msgs = array ( ) ; // Read something. $ read = @ fread ( $ this -> socket , 65535 ) ; if ( $ read === false || @ feof ( $ this -> socket ) ) { throw new ClientException ( 'Error reading' ) ; } $ this -> currentProcessingMessage .= $ read ; // If we have a complete message, then return it. Save the rest for // later. while ( ( $ marker = strpos ( $ this -> currentProcessingMessage , Message :: EOM ) ) ) { $ msg = substr ( $ this -> currentProcessingMessage , 0 , $ marker ) ; $ this -> currentProcessingMessage = substr ( $ this -> currentProcessingMessage , $ marker + strlen ( Message :: EOM ) ) ; $ msgs [ ] = $ msg ; } return $ msgs ; }
Reads a complete message over the stream until EOM.

@throws ClientException
@return \string[]
Reads a complete message over the stream until EOM .