add calls to flush_audio for say() and rtvi action

pipecat-ai · Sep 23, 2024 · 5bf1b9f · 5bf1b9f
1 parent a1024bb
commit 5bf1b9f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/pipecat/services/ai_services.py b/src/pipecat/services/ai_services.py
@@ -186,6 +186,7 @@ async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
 
     async def say(self, text: str):
         await self.process_frame(TextFrame(text=text), FrameDirection.DOWNSTREAM)
+        await self.flush_audio()
 
     async def _handle_interruption(self, frame: StartInterruptionFrame, direction: FrameDirection):
         self._current_sentence = ""
@@ -235,6 +236,7 @@ async def process_frame(self, frame: Frame, direction: FrameDirection):
                 await self.push_frame(frame, direction)
         elif isinstance(frame, TTSSpeakFrame):
             await self._push_tts_frames(frame.text)
+            await self.flush_audio()
         elif isinstance(frame, TTSModelUpdateFrame):
             await self.set_model(frame.model)
         elif isinstance(frame, TTSVoiceUpdateFrame):