From 51269aabbd25540e9062d3de70484d67f073950f Mon Sep 17 00:00:00 2001 From: Mark Backman Date: Tue, 22 Apr 2025 13:57:02 -0400 Subject: [PATCH] Added cancel method to WebsocketServerOutputTransport --- src/pipecat/transports/network/websocket_server.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/pipecat/transports/network/websocket_server.py b/src/pipecat/transports/network/websocket_server.py index c69709a22..7ca395922 100644 --- a/src/pipecat/transports/network/websocket_server.py +++ b/src/pipecat/transports/network/websocket_server.py @@ -200,6 +200,10 @@ class WebsocketServerOutputTransport(BaseOutputTransport): await super().stop(frame) await self._write_frame(frame) + async def cancel(self, frame: CancelFrame): + await super().cancel(frame) + await self._write_frame(frame) + async def cleanup(self): await super().cleanup() await self._transport.cleanup()