pipecat.connect module

Functions for connecting data sources.

pipecat.connect.concatenate(sources)

Concatenate records from multiple sources.

Yields all of the records from the first source, then all the records from the second source, and-so-on until every source has been consumed. Note that this means that it only makes sense to use sources that return a bounded number of records with concatenate()!

Parameters:sources (sequence of Record Generators, required) Yields:records (dict) – Returns records from each source in-turn.

pipecat.connect.multiplex(sources)

Interleave records from multiple sources.

Parameters:sources (sequence of Record Generators, required) Yields:records (dict) – Returns records from all sources as they arrive.