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

BaseInputTransport: broadcast SpeechControlParamsFrame

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-12-11 15:19:05 -08:00
parent c4c4b4107b
commit 49ebe34599
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/pipecat/transports/base_input.py
View File

@@ -223,8 +223,9 @@ class BaseInputTransport(FrameProcessor):
vad_params = self._params.vad_analyzer.params if self._params.vad_analyzer else None 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 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.broadcast_frame(
await self.push_frame(speech_frame) SpeechControlParamsFrame, vad_params=vad_params, turn_params=turn_params
)
# Start audio filter. # Start audio filter.
if self._params.audio_in_filter: if self._params.audio_in_filter:
@@ -342,13 +343,13 @@ class BaseInputTransport(FrameProcessor):
elif isinstance(frame, VADParamsUpdateFrame): elif isinstance(frame, VADParamsUpdateFrame):
if self.vad_analyzer: if self.vad_analyzer:
self.vad_analyzer.set_params(frame.params) self.vad_analyzer.set_params(frame.params)
speech_frame = SpeechControlParamsFrame( await self.broadcast_frame(
SpeechControlParamsFrame,
vad_params=frame.params, vad_params=frame.params,
turn_params=self._params.turn_analyzer.params turn_params=self._params.turn_analyzer.params
if self._params.turn_analyzer if self._params.turn_analyzer
else None, else None,
) )
await self.push_frame(speech_frame)
elif isinstance(frame, FilterUpdateSettingsFrame) and self._params.audio_in_filter: elif isinstance(frame, FilterUpdateSettingsFrame) and self._params.audio_in_filter:
await self._params.audio_in_filter.process_frame(frame) await self._params.audio_in_filter.process_frame(frame)
# Other frames # Other frames