diff --git a/src/pipecat/services/rime.py b/src/pipecat/services/rime.py index 6e2daccd6..bffe89f48 100644 --- a/src/pipecat/services/rime.py +++ b/src/pipecat/services/rime.py @@ -244,7 +244,9 @@ class RimeTTSService(AudioContextWordTTSService): async def flush_audio(self): if not self._context_id or not self._websocket: return + logger.trace(f"{self}: flushing audio") + await self._get_websocket().send(json.dumps({"text": " "})) self._context_id = None async def _receive_messages(self):