diff --git a/blivedm/client.py b/blivedm/client.py
index 8db237e..74bf5c1 100644
--- a/blivedm/client.py
+++ b/blivedm/client.py
@@ -540,6 +540,8 @@ class BLiveClient:
                     try:
                         body = json.loads(body.decode('utf-8'))
                         await self._handle_command(body)
+                    except asyncio.CancelledError:
+                        raise
                     except Exception:
                         logger.error('room=%d, body=%s', self.room_id, body)
                         raise