From 9632efec8cb79f477c17bf13de474f29e8c2d899 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Fri, 30 Jan 2026 10:05:02 -0800 Subject: [PATCH] VADProcessor: broadcast frames --- src/pipecat/processors/audio/vad_processor.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/pipecat/processors/audio/vad_processor.py b/src/pipecat/processors/audio/vad_processor.py index 2076eeeb3..074ea57e6 100644 --- a/src/pipecat/processors/audio/vad_processor.py +++ b/src/pipecat/processors/audio/vad_processor.py @@ -64,16 +64,16 @@ class VADProcessor(FrameProcessor): @self._vad_controller.event_handler("on_speech_started") async def on_speech_started(_controller): logger.debug(f"{self}: User started speaking") - await self.push_frame(VADUserStartedSpeakingFrame()) + await self.broadcast_frame(VADUserStartedSpeakingFrame) @self._vad_controller.event_handler("on_speech_stopped") async def on_speech_stopped(_controller): logger.debug(f"{self}: User stopped speaking") - await self.push_frame(VADUserStoppedSpeakingFrame()) + await self.broadcast_frame(VADUserStoppedSpeakingFrame) @self._vad_controller.event_handler("on_speech_activity") async def on_speech_activity(_controller): - await self.push_frame(UserSpeakingFrame()) + await self.broadcast_frame(UserSpeakingFrame) # Wire up frame pushing from controller to processor @self._vad_controller.event_handler("on_push_frame")