Added cancel method to WebsocketServerOutputTransport

2025-04-22 13:57:02 -04:00
parent 74ecc19e09
commit 51269aabbd
1 changed files with 4 additions and 0 deletions
--- 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()