async_queue

In-process worker bus backed by asyncio queues.

class pipecat.bus.local.async_queue.AsyncQueueBus(**kwargs)

Bases: WorkerBus

In-process bus that delivers messages via priority queues.

async publish(message: BusMessage) → None

Deliver a message to all local subscriber queues.

Parameters:

message – The bus message to deliver.