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