Skip to content

Commit 32562f3

Browse files
committed
sse mvc session close async when complete or timeout
1 parent dd775a0 commit 32562f3

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

mcp-spring/mcp-spring-webmvc/src/main/java/io/modelcontextprotocol/server/transport/WebMvcSseServerTransportProvider.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -264,13 +264,11 @@ private ServerResponse handleSseConnection(ServerRequest request) {
264264
sseBuilder.onComplete(() -> {
265265
logger.debug("SSE connection completed for session: {}", sessionId);
266266
// explicitly close the session when the SSE connection is completed
267-
session.close();
268-
sessions.remove(sessionId);
267+
session.closeGracefully().doOnSuccess(v -> sessions.remove(sessionId)).subscribe();
269268
});
270269
sseBuilder.onTimeout(() -> {
271270
logger.debug("SSE connection timed out for session: {}", sessionId);
272-
session.close();
273-
sessions.remove(sessionId);
271+
session.closeGracefully().doOnSuccess(v -> sessions.remove(sessionId)).subscribe();
274272
});
275273
this.sessions.put(sessionId, session);
276274

0 commit comments

Comments
 (0)