diff --git a/src/pipecat/services/elevenlabs.py b/src/pipecat/services/elevenlabs.py
index b2805b55a..e0b985411 100644
--- a/src/pipecat/services/elevenlabs.py
+++ b/src/pipecat/services/elevenlabs.py
@@ -392,6 +392,7 @@ class ElevenLabsTTSService(WordTTSService, WebsocketService):
                 await self._send_text("")
             except websockets.ConnectionClosed as e:
                 logger.warning(f"{self} keepalive error: {e}")
+                break
 
     async def _send_text(self, text: str):
         if self._websocket:
diff --git a/src/pipecat/services/websocket_service.py b/src/pipecat/services/websocket_service.py
index 48ddeadaa..9c942b019 100644
--- a/src/pipecat/services/websocket_service.py
+++ b/src/pipecat/services/websocket_service.py
@@ -87,6 +87,7 @@ class WebsocketService(ABC):
                 retry_count = 0  # Reset counter on successful message receive
             except websockets.ConnectionClosed as e:
                 logger.warning(f"{self} connection closed: {e}")
+                break
             except Exception as e:
                 retry_count += 1
                 if retry_count >= MAX_RETRIES: