Merge pull request #68 from nats-io/67-promise-complete

Fixed promise.complete not being called.
nats-io · Mar 8, 2024 · 505ecb9 · 505ecb9
2 parents 0ec2b00 + e7dc4e3
commit 505ecb9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/io/nats/vertx/impl/NatsStreamImpl.java b/src/main/java/io/nats/vertx/impl/NatsStreamImpl.java
@@ -317,6 +317,7 @@ public Future<Void> unsubscribe(final String subject) {
                     } else {
                         subscription.unsubscribe();
                         subscriptionMap.remove(subject);
+                        promise.complete();
                     }
                 } else {
                     dispatcherMap.remove(subject);