diff --git a/client/src/main/java/io/a2a/http/JdkA2AHttpClient.java b/client/src/main/java/io/a2a/http/JdkA2AHttpClient.java index e3b5c0c66..c3d5907a2 100644 --- 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 getAsyncSSE( Consumer messageConsumer, Consumer errorConsumer, Runnable completeRunnable) throws IOException, InterruptedException { - HttpRequest request = createRequestBuilder(false) + HttpRequest request = createRequestBuilder(true) .build(); return super.asyncRequest(request, messageConsumer, errorConsumer, completeRunnable); } @@ -180,7 +180,7 @@ public CompletableFuture postAsyncSSE( Consumer messageConsumer, Consumer errorConsumer, Runnable completeRunnable) throws IOException, InterruptedException { - HttpRequest request = createRequestBuilder(false) + HttpRequest request = createRequestBuilder(true) .build(); return super.asyncRequest(request, messageConsumer, errorConsumer, completeRunnable); }