async def METHOD_NAME(self):
    import asyncio
    while True:
        while not self._write_queue.empty():
            data = self._write_queue.get(block=False)
            if self.text_mode:
                payload = data.decode("UTF-8")
            else:
                payload = data
            await self._ws.send(payload)
            # logger.debug("Wrote %r bytes", len(data))
            self._write_responses.put(len(data))
        # Allow reading loop to progress
        await asyncio.sleep(0.01)