diff --git a/src/socketio/asyncio_pubsub_manager.py b/src/socketio/asyncio_pubsub_manager.py
index 54e24360..916c4a6f 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 @@ async def _thread(self):
         while True:
             try:
                 message = await self._listen()
+            except asyncio.CancelledError:  # pragma: no cover
+                break
             except:
                 import traceback
                 traceback.print_exc()