Handle CancelledError in async pubsub managers (Fixes miguelgrinberg#750)

miguelgrinberg · miguelgrinberg · commit a813bde0626c · 2021-07-13T10:24:53.000+01:00
diff --git 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 @@ async def _thread(self):
         while True:
             try:
                 message = await self._listen()
+            except asyncio.CancelledError:  # pragma: no cover
+                break
             except:
                 import traceback
                 traceback.print_exc()
