async def METHOD_NAME(self):
    """Async write loop to pull from the queue and send"""
    _LOGGER.info("Starting log sender")
    try:
        # send log history on socket open
        for msg in self._log_history:
            await self.send(msg)
        # keep sending and adding to history while socket open
        while not self._socket.closed:
            msg = await self._sender_queue.get()
            self.log_append(msg)
            await self.send(msg)
    except TypeError as e:
        if self._socket.closed:
            _LOGGER.info("Logging connection closed by client.")
        else:
            _LOGGER.exception(f"Unexpected TypeError: {e}")
    except (asyncio.CancelledError, futures.CancelledError):
        _LOGGER.info("Logging connection cancelled")
    # Hopefully get rid of the aiohttp connection reset errors
    except ConnectionResetError:
        _LOGGER.info("Logging connection reset")
    except Exception as err:
        _LOGGER.exception("Unexpected Exception: %s", err)
    _LOGGER.info("Stopping log sender")