(self, data)
Dispatch Engine.IO messages.
Dispatch Engine.IO messages.
Dispatch Engine . IO messages .
def _handle_eio_message(self, data):
        """Dispatch Engine.IO messages."""
        if self._binary_packet:
            pkt = self._binary_packet
            if pkt.add_attachment(data):
                self._binary_packet = None
                if pkt.packet_type == packet.BINARY_EVENT:
                    self._handle_event(pkt.namespace, pkt.id, pkt.data)
                else:
                    self._handle_ack(pkt.namespace, pkt.id, pkt.data)
        else:
            pkt = self.packet_class(encoded_packet=data)
            if pkt.packet_type == packet.CONNECT:
                self._handle_connect(pkt.namespace, pkt.data)
            elif pkt.packet_type == packet.DISCONNECT:
                self._handle_disconnect(pkt.namespace)
            elif pkt.packet_type == packet.EVENT:
                self._handle_event(pkt.namespace, pkt.id, pkt.data)
            elif pkt.packet_type == packet.ACK:
                self._handle_ack(pkt.namespace, pkt.id, pkt.data)
            elif pkt.packet_type == packet.BINARY_EVENT or \
                    pkt.packet_type == packet.BINARY_ACK:
                self._binary_packet = pkt
            elif pkt.packet_type == packet.CONNECT_ERROR:
                self._handle_error(pkt.namespace, pkt.data)
            else:
                raise ValueError('Unknown packet type.')
def _handle_eio_message ( self , data ) : if self . _binary_packet : pkt = self . _binary_packet if pkt . add_attachment ( data ) : self . _binary_packet = None if pkt . packet_type == packet . BINARY_EVENT : self . _handle_event ( pkt . namespace , pkt . id , pkt . data ) else : self . _handle_ack ( pkt . namespace , pkt . id , pkt . data ) else : pkt = self . packet_class ( encoded_packet = data ) if pkt . packet_type == packet . CONNECT : self . _handle_connect ( pkt . namespace , pkt . data ) elif pkt . packet_type == packet . DISCONNECT : self . _handle_disconnect ( pkt . namespace ) elif pkt . packet_type == packet . EVENT : self . _handle_event ( pkt . namespace , pkt . id , pkt . data ) elif pkt . packet_type == packet . ACK : self . _handle_ack ( pkt . namespace , pkt . id , pkt . data ) elif pkt . packet_type == packet . BINARY_EVENT or pkt . packet_type == packet . BINARY_ACK : self . _binary_packet = pkt elif pkt . packet_type == packet . CONNECT_ERROR : self . _handle_error ( pkt . namespace , pkt . data ) else : raise ValueError ( 'Unknown packet type.' )