-> rm | delete 'nats: connection is closed' msg for fut.cancel to ens…

…ure backward compatibility
ByteInternet · Aug 10, 2023 · ce4d765 · ce4d765
1 parent 63e3186
commit ce4d765
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/nats/aio/client.py b/nats/aio/client.py
@@ -689,7 +689,7 @@ async def _close(self, status: int, do_cbs: bool = True) -> None:
             # so cancel them here to unblock them.
             if sub._pending_next_msgs_calls:
                 for fut in sub._pending_next_msgs_calls.values():
-                    fut.cancel("nats: connection is closed")
+                    fut.cancel()
                 sub._pending_next_msgs_calls.clear()
         self._subs.clear()