wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

VADProcessor: broadcast frames

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2026-01-30 10:05:02 -08:00
parent 27dbfa1eda
commit 9632efec8c
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/pipecat/processors/audio/vad_processor.py
View File

@@ -64,16 +64,16 @@ class VADProcessor(FrameProcessor):
@self._vad_controller.event_handler("on_speech_started") @self._vad_controller.event_handler("on_speech_started")
async def on_speech_started(_controller): async def on_speech_started(_controller):
logger.debug(f"{self}: User started speaking") 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") @self._vad_controller.event_handler("on_speech_stopped")
async def on_speech_stopped(_controller): async def on_speech_stopped(_controller):
logger.debug(f"{self}: User stopped speaking") 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") @self._vad_controller.event_handler("on_speech_activity")
async def on_speech_activity(_controller): async def on_speech_activity(_controller):
await self.push_frame(UserSpeakingFrame()) await self.broadcast_frame(UserSpeakingFrame)
# Wire up frame pushing from controller to processor # Wire up frame pushing from controller to processor
@self._vad_controller.event_handler("on_push_frame") @self._vad_controller.event_handler("on_push_frame")