From e06bd6049ee9b9c3e9ede5771006189a46157336 Mon Sep 17 00:00:00 2001
From: gokuljs <gokuljs029@gmail.com>
Date: Fri, 29 Aug 2025 21:27:14 +0530
Subject: [PATCH] update flush  operation in flush audio function under rime
 tts

---
 src/pipecat/services/rime/tts.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/pipecat/services/rime/tts.py b/src/pipecat/services/rime/tts.py
index e18df2742..6ec0d5b8d 100644
--- 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):