update flush operation in flush audio function under rime tts

2025-08-29 21:27:14 +05:30
parent 77c34076f7
commit e06bd6049e
1 changed files with 1 additions and 1 deletions
--- a/src/pipecat/services/rime/tts.py
+++ b/src/pipecat/services/rime/tts.py
@@ -323,7 +323,7 @@ class RimeTTSService(AudioContextWordTTSService):
            return

        logger.trace(f"{self}: flushing audio")
-        await self._get_websocket().send(json.dumps({"text": " "}))
+        await self._get_websocket().send(json.dumps({ "operation": "flush" }))
        self._context_id = None

    async def _receive_messages(self):