code: async def recv(self):
          
          while self._connected:
              result = await self._recv_queue.get()
              if result:  # None = sentinel value = keep trying
                  return result
  
          raise ConnectionError('Not connected')
docs: Receives a packet of data through this connection mode.
  
          This method returns a coroutine.