We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6a5eb43 commit fb107f6Copy full SHA for fb107f6
1 file changed
mcp/src/main/java/io/modelcontextprotocol/client/transport/HttpClientStreamableHttpTransport.java
@@ -423,10 +423,6 @@ public Mono<Void> sendMessage(McpSchema.JSONRPCMessage sentMessage) {
423
}).flatMapMany(requestBuilder -> Flux.<ResponseEvent>create(responseEventSink -> {
424
425
// Create the async request with proper error handling and timeout
426
- // The key insight: the response body is consumed by the BodySubscriber
427
- // and flows through responseEventSink
428
- // The CompletableFuture<HttpResponse<Void>> completes when headers are
429
- // received, not when body is consumed
430
Mono.fromFuture(() -> this.httpClient.sendAsync(requestBuilder.build(),
431
this.toSendMessageBodySubscriber(responseEventSink)))
432
.doOnSuccess(response -> {
0 commit comments