From 5bfea84bd5c365e593b46e71e8f9d076beefd9ab Mon Sep 17 00:00:00 2001 From: Gokul Js Date: Mon, 8 Dec 2025 20:30:46 +0530 Subject: [PATCH] Refactor RimeNonJsonTTSService to extend WebsocketTTSService, enhancing WebSocket functionality and improving code clarity --- src/pipecat/services/rime/tts.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/pipecat/services/rime/tts.py b/src/pipecat/services/rime/tts.py index 8b81d5b86..ed8afae59 100644 --- a/src/pipecat/services/rime/tts.py +++ b/src/pipecat/services/rime/tts.py @@ -33,8 +33,8 @@ from pipecat.frames.frames import ( from pipecat.processors.frame_processor import FrameDirection from pipecat.services.tts_service import ( AudioContextWordTTSService, - InterruptibleTTSService, TTSService, + WebsocketTTSService, ) from pipecat.transcriptions import language from pipecat.transcriptions.language import Language, resolve_language @@ -581,7 +581,7 @@ class RimeHttpTTSService(TTSService): yield TTSStoppedFrame() -class RimeNonJsonTTSService(InterruptibleTTSService): +class RimeNonJsonTTSService(WebsocketTTSService): """Pipecat TTS service for Rime's non-JSON WebSocket API. This service enables Text-to-Speech synthesis over WebSocket endpoints @@ -770,7 +770,7 @@ class RimeNonJsonTTSService(InterruptibleTTSService): # Send EOS command to gracefully close await self._websocket.send("") await self._websocket.close() - logger.debug("Disconnected from Rime None json websocket") + logger.debug("Disconnected from Rime non json websocket") except Exception as e: logger.error(f"{self} exception: {e}") await self.push_error(ErrorFrame(error=f"{self} error: {e}"))