AsyncGenerator

class pipecat.processors.async_generator.AsyncGeneratorProcessor(*, serializer, **kwargs)[source]

Bases: FrameProcessor

Parameters:: serializer (FrameSerializer)

async process_frame(frame, direction)[source]

Parameters:

frame (Frame)
direction (FrameDirection)

async generator()[source]

Return type:: AsyncGenerator[Any, None]