code: async def _recv_loop(self):
          
          while self._connected:
              try:
                  data = await self._recv()
              except asyncio.CancelledError:
                  break
              except Exception as e:
                  if isinstance(e, (IOError, asyncio.IncompleteReadError)):
                      msg = 'The server closed the connection'
                      self._log.info(msg)
                  elif isinstance(e, InvalidChecksumError):
                      msg = 'The server response had an invalid checksum'
                      self._log.info(msg)
                  else:
                      msg = 'Unexpected exception in the receive loop'
                      self._log.exception(msg)
  
                  await self.disconnect()
  
                  # Add a sentinel value to unstuck recv
                  if self._recv_queue.empty():
                      self._recv_queue.put_nowait(None)
  
                  break
  
              try:
                  await self._recv_queue.put(data)
              except asyncio.CancelledError:
                  break
docs: This loop is constantly putting items on the queue as they're read.