pipecat/tests/test_pipeline.py | test_pipeline_start_metadata, test_task_single, test_task_observers, CustomObserver, test_task_add_observer (+16) |
pipecat/examples/foundational/22d-natural-conversation-gemini-audio.py | TurnDetectionLLM, run_bot, on_client_disconnected, bot, AudioAccumulator (+14) |
pipecat/examples/foundational/22c-natural-conversation-mixed-llms.py | TurnDetectionLLM, run_bot, on_client_disconnected, bot, on_client_connected (+11) |
pipecat/examples/foundational/22b-natural-conversation-proposal.py | TurnDetectionLLM, run_bot, on_client_disconnected, bot, on_client_connected (+11) |
pipecat/src/pipecat/pipeline/task.py | PipelineParams, PipelineTask, event_handler, set_reached_upstream_filter, set_reached_downstream_filter (+9) |
pipecat/examples/foundational/25-google-audio-in.py | run_bot, on_client_disconnected, bot, on_client_connected, UserAudioCollector (+7) |
pipecat/examples/foundational/07s-interruptible-google-audio-in.py | run_bot, on_client_disconnected, bot, on_client_connected, UserAudioCollector (+6) |
pipecat/examples/foundational/28-user-assistant-turns.py | TranscriptHandler, run_bot, on_client_disconnected, bot, on_client_connected (+5) |
pipecat/examples/foundational/17-detect-user-idle.py | IdleHandler, run_bot, on_client_disconnected, bot, on_client_connected (+4) |
pipecat/examples/foundational/39c-multiple-mcp.py | run_bot, on_client_disconnected, bot, on_client_connected, process_frame (+3) |