Explicitly delete consumer after iterating over kv keys

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
nats-io · Jan 26, 2023 · 250547c · 250547c
1 parent 16306f6
commit 250547c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/async-nats/src/jetstream/kv/mod.rs b/async-nats/src/jetstream/kv/mod.rs
@@ -675,6 +675,8 @@ impl Store {
             })
             .await?;
 
+        let consumer_name = consumer.info.name.clone();
+
         let mut entries = History {
             done: consumer.info.num_pending == 0,
             subscription: consumer.messages().await?,
@@ -689,6 +691,7 @@ impl Store {
                 keys.insert(entry.key);
             }
         }
+        self.stream.delete_consumer(&consumer_name).await?;
         Ok(keys.into_iter())
     }
 }