fix: client sse

chenkangqiang · chenkangqiang · commit f2545c3b3024 · 2025-07-10T19:37:59.000+08:00
diff --git a/client/src/main/java/io/a2a/http/JdkA2AHttpClient.java b/client/src/main/java/io/a2a/http/JdkA2AHttpClient.java
@@ -141,7 +141,7 @@ public CompletableFuture<Void> getAsyncSSE(
                 Consumer<String> messageConsumer,
                 Consumer<Throwable> errorConsumer,
                 Runnable completeRunnable) throws IOException, InterruptedException {
-            HttpRequest request = createRequestBuilder(false)
+            HttpRequest request = createRequestBuilder(true)
                     .build();
             return super.asyncRequest(request, messageConsumer, errorConsumer, completeRunnable);
         }

Original file line number	Diff line number	Diff line change
`@@ -141,7 +141,7 @@ public CompletableFuture<Void> getAsyncSSE(`
`141`	`141`	`Consumer<String> messageConsumer,`
`142`	`142`	`Consumer<Throwable> errorConsumer,`
`143`	`143`	`Runnable completeRunnable) throws IOException, InterruptedException {`
`144`		`- HttpRequest request = createRequestBuilder(false)`
	`144`	`+ HttpRequest request = createRequestBuilder(true)`
`145`	`145`	`.build();`
`146`	`146`	`return super.asyncRequest(request, messageConsumer, errorConsumer, completeRunnable);`
`147`	`147`	`}`