From a813bde0626c16fe693db74cbc2ea7c331a177d3 Mon Sep 17 00:00:00 2001 From: Miguel Grinberg Date: Tue, 13 Jul 2021 10:24:34 +0100 Subject: [PATCH] Handle CancelledError in async pubsub managers (Fixes #750) --- src/socketio/asyncio_pubsub_manager.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/socketio/asyncio_pubsub_manager.py b/src/socketio/asyncio_pubsub_manager.py index 54e2436..916c4a6 100644 --- a/src/socketio/asyncio_pubsub_manager.py +++ b/src/socketio/asyncio_pubsub_manager.py @@ -1,3 +1,4 @@ +import asyncio from functools import partial import uuid @@ -148,6 +149,8 @@ class AsyncPubSubManager(AsyncManager): while True: try: message = await self._listen() + except asyncio.CancelledError: # pragma: no cover + break except: import traceback traceback.print_exc()