pipecat.queue module

Functions for working with queues.

pipecat.queue.receive(queue)

Receive records from a queue.

Parameters:queue (queue.Queue, required) Yields:records (dict)

pipecat.queue.send(source, queue, shutdown=None)

Send records from a source to a queue.

Parameters:

• source (Record generator, required)
• queue (queue.Queue, required)
• shutdown (threading.Event, optional.) – Set the event to safely stop sending from another thread.