code: async def _send_loop(self):
          
          try:
              while self._connected:
                  self._send(await self._send_queue.get())
                  await self._writer.drain()
          except asyncio.CancelledError:
              pass
          except Exception as e:
              if isinstance(e, IOError):
                  self._log.info('The server closed the connection while sending')
              else:
                  self._log.exception('Unexpected exception in the send loop')
  
              await self.disconnect()
docs: This loop is constantly popping items off the queue to send them.