FunctionFilter

class pipecat.processors.filters.function_filter.FunctionFilter(filter, direction=FrameDirection.DOWNSTREAM)[source]

Bases: FrameProcessor

Parameters:

  • filter (Callable[[Frame], Awaitable[bool]])

  • direction (FrameDirection)

async process_frame(frame, direction)[source]
Parameters:

  • frame (Frame)

  • direction (FrameDirection)