Only retain non-closed subscriptions on reconnect

nats-io · May 27, 2022 · feb2186 · feb2186
1 parent 05cd043
commit feb2186
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/async-nats/src/lib.rs b/async-nats/src/lib.rs
@@ -697,6 +697,9 @@ impl ConnectionHandler {
         let (_, connection) = self.connector.connect().await?;
         self.connection = connection;
 
+        self.subscriptions
+            .retain(|_, subscription| !subscription.sender.is_closed());
+
         for (sid, subscription) in &self.subscriptions {
             self.connection
                 .write_op(ClientOp::Subscribe {