local

Local (in-process) bus implementations.

class pipecat.bus.local.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.

Submodules

• async_queue
  • AsyncQueueBus
    • AsyncQueueBus.publish()