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()