queue

Priority queue for bus messages.

class pipecat.bus.queue.BusMessageQueue[source]

Bases: PriorityQueue

Priority queue that delivers system messages before normal messages.

Messages that extend BusSystemMessage (e.g. cancel messages) get high priority. All other messages are delivered in FIFO order at normal priority.

__init__()[source]

Initialize the BusMessageQueue.

put_nowait(item) → None[source]

Add a message to the queue with automatic priority assignment.

Parameters:

item – The bus message to enqueue.

async put(item) → None[source]

Add a message to the queue with automatic priority assignment.

Parameters:

item – The bus message to enqueue.

async get() → Any[source]

Get the next message, with system messages prioritized.