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

fix issue with infinite loop when websocket disconnects

Browse Source
This commit is contained in:
jay
2025-12-15 23:06:35 +05:30
parent 4f848e9631
commit 59c3abeb92
1 changed files with 2 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/pipecat/services/elevenlabs/stt.py
View File

@@ -690,8 +690,8 @@ class ElevenLabsRealtimeSTTService(WebsocketSTTService):
return self._websocket return self._websocket
raise Exception("Websocket not connected") raise Exception("Websocket not connected")
async def _process_messages(self): async def _receive_messages(self):
"""Process incoming WebSocket messages.""" """Continuously receive and process WebSocket messages."""
async for message in self._get_websocket(): async for message in self._get_websocket():
try: try:
data = json.loads(message) data = json.loads(message)
@@ -700,13 +700,6 @@ class ElevenLabsRealtimeSTTService(WebsocketSTTService):
logger.warning(f"Received non-JSON message: {message}") logger.warning(f"Received non-JSON message: {message}")
except Exception as e: except Exception as e:
logger.error(f"Error processing message: {e}") logger.error(f"Error processing message: {e}")
async def _receive_messages(self):
"""Continuously receive and process WebSocket messages."""
try:
await self._process_messages()
except Exception as e:
logger.warning(f"{self} WebSocket connection closed: {e}")
# Connection closed, will reconnect on next audio chunk # Connection closed, will reconnect on next audio chunk
async def _process_response(self, data: dict): async def _process_response(self, data: dict):