modelcontextprotocol/java-sdk
Watch
1
0
Fork
You've already forked java-sdk
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: Fix SseLineSubscriber lacking request. (#507)

Browse source 
Signed-off-by: He-Pin <hepin1989@gmail.com>
This commit is contained in:
He-Pin(kerr) 2025-08-25 21:46:17 +08:00 • committed by GitHub
commit 94c03505c1
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 4 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

5
mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java
View file

@ -141,7 +141,6 @@ class ResponseSubscribers {
@Override @Override
protected void hookOnNext(String line) { protected void hookOnNext(String line) {
if (line.isEmpty()) { if (line.isEmpty()) {
// Empty line means end of event // Empty line means end of event
if (this.eventBuilder.length() > 0) { if (this.eventBuilder.length() > 0) {
@ -158,23 +157,27 @@ class ResponseSubscribers {
if (matcher.find()) { if (matcher.find()) {
this.eventBuilder.append(matcher.group(1).trim()).append("\n"); this.eventBuilder.append(matcher.group(1).trim()).append("\n");
} }
upstream().request(1);
} }
else if (line.startsWith("id:")) { else if (line.startsWith("id:")) {
var matcher = EVENT_ID_PATTERN.matcher(line); var matcher = EVENT_ID_PATTERN.matcher(line);
if (matcher.find()) { if (matcher.find()) {
this.currentEventId.set(matcher.group(1).trim()); this.currentEventId.set(matcher.group(1).trim());
} }
upstream().request(1);
} }
else if (line.startsWith("event:")) { else if (line.startsWith("event:")) {
var matcher = EVENT_TYPE_PATTERN.matcher(line); var matcher = EVENT_TYPE_PATTERN.matcher(line);
if (matcher.find()) { if (matcher.find()) {
this.currentEventType.set(matcher.group(1).trim()); this.currentEventType.set(matcher.group(1).trim());
} }
upstream().request(1);
} }
else if (line.startsWith(":")) { else if (line.startsWith(":")) {
// Ignore comment lines starting with ":" // Ignore comment lines starting with ":"
// This is a no-op, just to skip comments // This is a no-op, just to skip comments
logger.debug("Ignoring comment line: {}", line); logger.debug("Ignoring comment line: {}", line);
upstream().request(1);
} }
else { else {
// If the response is not successful, emit an error // If the response is not successful, emit an error