wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

transport(websocket): fix cancel

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-08-01 18:09:16 -07:00
parent 4d9b7cdd61
commit 6376c2f6aa
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipecat/transports/network/websocket_server.py
View File

@@ -71,7 +71,7 @@ class WebsocketServerInputTransport(BaseInputTransport):
async def cancel(self, frame: CancelFrame): async def cancel(self, frame: CancelFrame):
await super().cancel(frame) await super().cancel(frame)
self._server_task.cancel() self._stop_server_event.set()
await self._server_task await self._server_task
async def _server_task_handler(self): async def _server_task_handler(self):