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

TTSService: pause before processing TTSSpeakFrame

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-09-19 08:20:56 -07:00
parent 367200c0ad
commit 74fd72ca79
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/pipecat/services/tts_service.py
View File

@@ -330,10 +330,10 @@ class TTSService(AIService):
elif isinstance(frame, TTSSpeakFrame): elif isinstance(frame, TTSSpeakFrame):
# Store if we were processing text or not so we can set it back. # Store if we were processing text or not so we can set it back.
processing_text = self._processing_text processing_text = self._processing_text
await self._push_tts_frames(frame.text)
# We pause processing incoming frames because we are sending data to # We pause processing incoming frames because we are sending data to
# the TTS. We pause to avoid audio overlapping. # the TTS. We pause to avoid audio overlapping.
await self._maybe_pause_frame_processing() await self._maybe_pause_frame_processing(force=True)
await self._push_tts_frames(frame.text)
await self.flush_audio() await self.flush_audio()
self._processing_text = processing_text self._processing_text = processing_text
elif isinstance(frame, TTSUpdateSettingsFrame): elif isinstance(frame, TTSUpdateSettingsFrame):
@@ -380,8 +380,11 @@ class TTSService(AIService):
for filter in self._text_filters: for filter in self._text_filters:
await filter.handle_interruption() await filter.handle_interruption()
async def _maybe_pause_frame_processing(self): async def _maybe_pause_frame_processing(self, force: bool = False):
if self._processing_text and self._pause_frame_processing: if not self._processing_text and not force:
return
if self._pause_frame_processing:
await self.pause_processing_frames() await self.pause_processing_frames()
async def _maybe_resume_frame_processing(self): async def _maybe_resume_frame_processing(self):