feat: unload partitions when not publishing for better performance

googleapis · Dec 8, 2022 · d2bdb77 · d2bdb77
1 parent f1666be
commit d2bdb77
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...ubsublite/src/main/java/com/google/cloud/pubsublite/internal/wire/UnloadingPublisher.java b/...ubsublite/src/main/java/com/google/cloud/pubsublite/internal/wire/UnloadingPublisher.java
@@ -54,6 +54,7 @@ protected synchronized void doStop() {
     alarmFuture.cancel(false);
     if (!publisher.isPresent()) {
       notifyStopped();
+      return;
     }
     publisher
         .get()