From dd6e61f7f5d97ae92b1b0f9b1254a57dd86968e7 Mon Sep 17 00:00:00 2001 From: taobaorun Date: Wed, 20 Aug 2025 00:59:19 +0800 Subject: [PATCH 1/3] fix SseLineSubscriber will not request after default 256 request --- .../client/transport/ResponseSubscribers.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java b/mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java index 296d1a17d..e0720918a 100644 --- a/mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java +++ b/mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java @@ -141,7 +141,7 @@ protected void hookOnSubscribe(Subscription subscription) { @Override protected void hookOnNext(String line) { - + request(1); if (line.isEmpty()) { // Empty line means end of event if (this.eventBuilder.length() > 0) { From f60e3d34956fcbf11805c526bfa25d9bffa7fc78 Mon Sep 17 00:00:00 2001 From: taobaorun Date: Thu, 21 Aug 2025 20:32:01 +0800 Subject: [PATCH 2/3] request after end of event --- .../client/transport/ResponseSubscribers.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java b/mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java index e0720918a..40f3727ad 100644 --- a/mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java +++ b/mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java @@ -141,7 +141,6 @@ protected void hookOnSubscribe(Subscription subscription) { @Override protected void hookOnNext(String line) { - request(1); if (line.isEmpty()) { // Empty line means end of event if (this.eventBuilder.length() > 0) { @@ -150,6 +149,7 @@ protected void hookOnNext(String line) { this.sink.next(new SseResponseEvent(responseInfo, sseEvent)); this.eventBuilder.setLength(0); + request(1); } } else { From 12aa8f5eebe094e8126ebd63cc671102ff963b65 Mon Sep 17 00:00:00 2001 From: taobaorun Date: Thu, 21 Aug 2025 20:41:04 +0800 Subject: [PATCH 3/3] request after end of event --- .../client/transport/ResponseSubscribers.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java b/mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java index 40f3727ad..a97b5c155 100644 --- a/mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java +++ b/mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java @@ -149,7 +149,6 @@ protected void hookOnNext(String line) { this.sink.next(new SseResponseEvent(responseInfo, sseEvent)); this.eventBuilder.setLength(0); - request(1); } } else { @@ -183,6 +182,7 @@ else if (line.startsWith(":")) { } } + request(1); } @Override