From 49ebe345999b8db72ada52606b80349bc33d7b61 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 11 Dec 2025 15:19:05 -0800 Subject: [PATCH] BaseInputTransport: broadcast SpeechControlParamsFrame --- src/pipecat/transports/base_input.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/pipecat/transports/base_input.py b/src/pipecat/transports/base_input.py index c69328e9f..7e678a30c 100644 --- a/src/pipecat/transports/base_input.py +++ b/src/pipecat/transports/base_input.py @@ -223,8 +223,9 @@ class BaseInputTransport(FrameProcessor): vad_params = self._params.vad_analyzer.params if self._params.vad_analyzer else None turn_params = self._params.turn_analyzer.params if self._params.turn_analyzer else None - speech_frame = SpeechControlParamsFrame(vad_params=vad_params, turn_params=turn_params) - await self.push_frame(speech_frame) + await self.broadcast_frame( + SpeechControlParamsFrame, vad_params=vad_params, turn_params=turn_params + ) # Start audio filter. if self._params.audio_in_filter: @@ -342,13 +343,13 @@ class BaseInputTransport(FrameProcessor): elif isinstance(frame, VADParamsUpdateFrame): if self.vad_analyzer: self.vad_analyzer.set_params(frame.params) - speech_frame = SpeechControlParamsFrame( + await self.broadcast_frame( + SpeechControlParamsFrame, vad_params=frame.params, turn_params=self._params.turn_analyzer.params if self._params.turn_analyzer else None, ) - await self.push_frame(speech_frame) elif isinstance(frame, FilterUpdateSettingsFrame) and self._params.audio_in_filter: await self._params.audio_in_filter.process_frame(frame) # Other frames