diff --git a/src/pipecat/transports/network/fastapi_websocket.py b/src/pipecat/transports/network/fastapi_websocket.py index a256134a7..d3e3362b4 100644 --- a/src/pipecat/transports/network/fastapi_websocket.py +++ b/src/pipecat/transports/network/fastapi_websocket.py @@ -419,12 +419,7 @@ class FastAPIWebsocketOutputTransport(BaseOutputTransport): Args: frame: The output audio frame to write. """ - if self._client.is_closing: - return - - if not self._client.is_connected: - # Simulate audio playback with a sleep. - await self._write_audio_sleep() + if self._client.is_closing or not self._client.is_connected: return frame = OutputAudioRawFrame( diff --git a/src/pipecat/transports/network/websocket_server.py b/src/pipecat/transports/network/websocket_server.py index e957b01be..ffeee5338 100644 --- a/src/pipecat/transports/network/websocket_server.py +++ b/src/pipecat/transports/network/websocket_server.py @@ -353,8 +353,6 @@ class WebsocketServerOutputTransport(BaseOutputTransport): frame: The output audio frame to write. """ if not self._websocket: - # Simulate audio playback with a sleep. - await self._write_audio_sleep() return frame = OutputAudioRawFrame(