pipecat.queue module

Functions for working with queues.

pipecat.queue.receive(queue)

Receive records from a queue.

Queues are a handy mechanism for passing data between threads. Use this function to receive records sent over a queue by pipecat.queue.send().

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

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

Send records from a source to a queue.

Queues are a handy mechanism for passing data between threads. Use this function to send records over a queue to pipecat.queue.receive().

Parameters:

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