feat: unload partitions when not publishing for better performance

dpcollins-google · dpcollins-google · commit 7921de9aa3c1 · 2023-02-03T10:58:39.000-05:00
diff --git a/google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/internal/wire/UnloadingPublisher.java b/google-cloud-pubsublite/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()

Original file line number	Diff line number	Diff line change
`@@ -54,6 +54,7 @@ protected synchronized void doStop() {`
`54`	`54`	`alarmFuture.cancel(false);`
`55`	`55`	`if (!publisher.isPresent()) {`
`56`	`56`	`notifyStopped();`
	`57`	`+ return;`
`57`	`58`	`}`
`58`	`59`	`publisher`
`59`	`60`	`.get()`