def _read_socket(self):
        """ Process incoming messages from socket. """
        while True:
            base_bytes = self._socket.recv(BASE_SIZE)
            base = basemessage.parse(base_bytes)
            payload_bytes = self._socket.recv(base.payload_length)
            self._handle_message(packet.parse(base_bytes + payload_bytes))
def _read_socket ( self ) : while True : base_bytes = self . _socket . recv ( BASE_SIZE ) base = basemessage . parse ( base_bytes ) payload_bytes = self . _socket . recv ( base . payload_length ) self . _handle_message ( packet . parse ( base_bytes + payload_bytes ) )
Process incoming messages from socket.