Searched refs:_drain_queue (Results 1 – 1 of 1) sorted by relevance
79 drain_queue = asyncio.create_task(self._drain_queue())94 async def _drain_queue(self): member in LogMonitor