From e7dc4e3f92034af80f0c2e666b8b11fd5037eb37 Mon Sep 17 00:00:00 2001 From: scottf Date: Fri, 8 Mar 2024 14:31:16 -0500 Subject: [PATCH] Fixed promise.complete not being called. --- src/main/java/io/nats/vertx/impl/NatsStreamImpl.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/io/nats/vertx/impl/NatsStreamImpl.java b/src/main/java/io/nats/vertx/impl/NatsStreamImpl.java index 40e9b79..7e2baab 100644 --- 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 unsubscribe(final String subject) { } else { subscription.unsubscribe(); subscriptionMap.remove(subject); + promise.complete(); } } else { dispatcherMap.remove(subject);