Handle close before start.

kinyoklion · kinyoklion · commit 9c43cbbf0e6c · 2026-01-15T16:56:49.000-08:00
diff --git a/lib/sdk/server/src/main/java/com/launchdarkly/sdk/server/StreamingSynchronizerImpl.java b/lib/sdk/server/src/main/java/com/launchdarkly/sdk/server/StreamingSynchronizerImpl.java
@@ -180,7 +180,8 @@ private Thread getRunThread() {
 
     @Override
     public CompletableFuture<FDv2SourceResult> next() {
-        if (!started.getAndSet(true)) {
+        // If we are already closed, don't start the stream.
+        if (!started.getAndSet(true) && !closed.get()) {
             startStream();
         }
         return CompletableFuture.anyOf(shutdownFuture, resultQueue.take())

Original file line number	Diff line number	Diff line change
`@@ -180,7 +180,8 @@ private Thread getRunThread() {`
`180`	`180`
`181`	`181`	`@Override`
`182`	`182`	`public CompletableFuture<FDv2SourceResult> next() {`
`183`		`- if (!started.getAndSet(true)) {`
	`183`	`+ // If we are already closed, don't start the stream.`
	`184`	`+ if (!started.getAndSet(true) && !closed.get()) {`
`184`	`185`	`startStream();`
`185`	`186`	`}`
`186`	`187`	`return CompletableFuture.anyOf(shutdownFuture, resultQueue.take())`