code: def receive(self, data):
          
          self._incoming_segments_queue.put(data)
          if not self._in_handshake():
              self._flush_incoming_buffer()
docs: :param data:
          :type data: bytes
          :return:
          :rtype: