code: async def consume(self):
          
          while True:
              coro = await self._queue.get()
              assert asyncio.iscoroutine(coro)
              await coro
docs: Consume coroutines from the queue by executing them.