protected function readToBuffer()
    {
        $this->ThrowOnConnectionInvalid();
        $message = stream_socket_recvfrom($this->connection, 1024, 0, $peer);
        //$message = fread($conn,1024);
        if ($message !== '' && $message !== false) {
            $this->buffer->pushData($message);
            foreach ($this->buffer->getMessages() as $messageData) {
                $messageData = unserialize($messageData);
                $this->emit('message', array($this, $messageData));
            }
        } else {
            $this->close();
        }
    }
protected function readToBuffer()
    {
        $this->ThrowOnConnectionInvalid();
        $message = stream_socket_recvfrom($this->connection, 1024, 0, $peer);
        //$message = fread($conn,1024);
        if ($message !== '' && $message !== false) {
            $this->buffer->pushData($message);
            foreach ($this->buffer->getMessages() as $messageData) {
                $messageData = unserialize($messageData);
                $this->emit('message', array($this, $messageData));
            }
        } else {
            $this->close();
        }
    }
protected function readToBuffer ( ) { $ this -> ThrowOnConnectionInvalid ( ) ; $ message = stream_socket_recvfrom ( $ this -> connection , 1024 , 0 , $ peer ) ; //$message = fread($conn,1024);
 if ( $ message !== '' && $ message !== false ) { $ this -> buffer -> pushData ( $ message ) ; foreach ( $ this -> buffer -> getMessages ( ) as $ messageData ) { $ messageData = unserialize ( $ messageData ) ; $ this -> emit ( 'message' , array ( $ this , $ messageData ) ) ; } } else { $ this -> close ( ) ; } }
reads a block of data to the buffer
reads a block of data to the buffer