channels_demultiplexer.queue module

class channels_demultiplexer.queue.MessageQueue(maxsize=0, *, loop=None)

Bases: asyncio.queues.Queue

Queue for messages waiting to be processed by a consumer.

async get()

Remove, mark done and return an item from the queue. If queue is empty, wait until an item is available.