anycall/packetprotocol.py
def dataReceived(self, data):
        """
        Do not overwrite this method. Instead implement `on_...` methods for the
        registered typenames to handle incomming packets.
        """
        
        self._unprocessed_data.enqueue(data)
        
        
        while True:
            if len(self._unprocessed_data) < self._header.size:
                return # not yet enough data
            
            hdr_data = self._unprocessed_data.peek(self._header.size)
            packet_length, typekey = self._header.unpack(hdr_data)
            total_length = self._header.size + packet_length
            
            if len(self._unprocessed_data) < total_length:
                return # not yet enough data
            
            self._unprocessed_data.drop(self._header.size)
            packet = self._unprocessed_data.dequeue(packet_length)
            
            self._start_receive = None
            
            typename = self._type_register.get(typekey, None)
            if typename is None:
                self.on_unregistered_type(typekey, packet)
            else:
                self.packet_received(typename, packet)
def dataReceived(self, data):
        """
        Do not overwrite this method. Instead implement `on_...` methods for the
        registered typenames to handle incomming packets.
        """
        
        self._unprocessed_data.enqueue(data)
        
        
        while True:
            if len(self._unprocessed_data) < self._header.size:
                return # not yet enough data
            
            hdr_data = self._unprocessed_data.peek(self._header.size)
            packet_length, typekey = self._header.unpack(hdr_data)
            total_length = self._header.size + packet_length
            
            if len(self._unprocessed_data) < total_length:
                return # not yet enough data
            
            self._unprocessed_data.drop(self._header.size)
            packet = self._unprocessed_data.dequeue(packet_length)
            
            self._start_receive = None
            
            typename = self._type_register.get(typekey, None)
            if typename is None:
                self.on_unregistered_type(typekey, packet)
            else:
                self.packet_received(typename, packet)
def dataReceived ( self , data ) : self . _unprocessed_data . enqueue ( data ) while True : if len ( self . _unprocessed_data ) < self . _header . size : return # not yet enough data hdr_data = self . _unprocessed_data . peek ( self . _header . size ) packet_length , typekey = self . _header . unpack ( hdr_data ) total_length = self . _header . size + packet_length if len ( self . _unprocessed_data ) < total_length : return # not yet enough data self . _unprocessed_data . drop ( self . _header . size ) packet = self . _unprocessed_data . dequeue ( packet_length ) self . _start_receive = None typename = self . _type_register . get ( typekey , None ) if typename is None : self . on_unregistered_type ( typekey , packet ) else : self . packet_received ( typename , packet )
Do not overwrite this method. Instead implement `on_...` methods for the
        registered typenames to handle incomming packets.
Do not overwrite this method . Instead implement on_ ... methods for the registered typenames to handle incomming packets .