(self, queue, handler)
Continually fetch commands from the queue and handle them
Continually fetch commands from the queue and handle them
Continually fetch commands from the queue and handle them
async def _consumer_loop(self, queue, handler):
        """Continually fetch commands from the queue and handle them"""
        logger.debug(f"Consumer loop is ready with handler {handler.__qualname__}()")
        self._ready.set()

        while True:
            on_done: asyncio.Event
            command, on_done = await queue.get()
            self.handle_in_background(queue, handler, command, on_done)
async def _consumer_loop ( self , queue , handler ) : logger . debug ( f"Consumer loop is ready with handler {handler.__qualname__}()" ) self . _ready . set ( ) while True : on_done : asyncio . Event command , on_done = await queue . get ( ) self . handle_in_background ( queue , handler , command , on_done )