def data_received()

in pyignite/connection/aio_connection.py [0:0]

• 11 lines of code
• 5 McCabe index (conditional complexity)

    def data_received(self, data: bytes) -> None:
        self._buffer += data
        while self.__has_full_response():
            packet_sz = self.__packet_size(self._buffer)
            packet = self._buffer[0:packet_sz]
            if not self._handshake_fut.done():
                hs_response = self.__parse_handshake(packet, self._conn.client)
                self._handshake_fut.set_result(hs_response)
            elif not self._handshake_fut.cancelled() or not self._handshake_fut.exception():
                self._conn.process_message(packet)
            self._buffer = self._buffer[packet_sz:len(self._buffer)]