wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refactor RimeNonJsonTTSService to extend InterruptibleTTSService, removing dependency on WebsocketTTSService and streamlining audio interruption handling.

Browse Source
This commit is contained in:
Gokul Js
2025-12-10 04:56:52 +05:30
parent 2a6a0d83db
commit 455579ffcc
1 changed files with 2 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/pipecat/services/rime/tts.py
View File

@@ -33,8 +33,8 @@ from pipecat.frames.frames import (
from pipecat.processors.frame_processor import FrameDirection from pipecat.processors.frame_processor import FrameDirection
from pipecat.services.tts_service import ( from pipecat.services.tts_service import (
AudioContextWordTTSService, AudioContextWordTTSService,
InterruptibleTTSService,
TTSService, TTSService,
WebsocketTTSService,
) )
from pipecat.transcriptions.language import Language, resolve_language from pipecat.transcriptions.language import Language, resolve_language
from pipecat.utils.text.base_text_aggregator import BaseTextAggregator from pipecat.utils.text.base_text_aggregator import BaseTextAggregator
@@ -614,7 +614,7 @@ class RimeHttpTTSService(TTSService):
yield TTSStoppedFrame() yield TTSStoppedFrame()
class RimeNonJsonTTSService(WebsocketTTSService): class RimeNonJsonTTSService(InterruptibleTTSService):
"""Pipecat TTS service for Rime's non-JSON WebSocket API. """Pipecat TTS service for Rime's non-JSON WebSocket API.
This service enables Text-to-Speech synthesis over WebSocket endpoints This service enables Text-to-Speech synthesis over WebSocket endpoints
@@ -818,14 +818,6 @@ class RimeNonJsonTTSService(WebsocketTTSService):
return self._websocket return self._websocket
raise Exception("Websocket not connected") raise Exception("Websocket not connected")
async def _handle_interruption(self, frame: InterruptionFrame, direction: FrameDirection):
"""Handle interruption by clearing buffer."""
await super()._handle_interruption(frame, direction)
await self.stop_all_metrics()
if self._websocket:
# Send CLEAR command to clear buffer
await self._websocket.send("<CLEAR>")
async def flush_audio(self): async def flush_audio(self):
"""Flush any pending audio synthesis.""" """Flush any pending audio synthesis."""
if not self._websocket: if not self._websocket: