Skip to content

Commit 3af9568

Browse files
committed
Improve comments
Signed-off-by: Dariusz Jędrzejczyk <dariusz.jedrzejczyk@broadcom.com>
1 parent 96c7d48 commit 3af9568

File tree

2 files changed

+2
-6
lines changed

2 files changed

+2
-6
lines changed

mcp-core/src/main/java/io/modelcontextprotocol/server/transport/HttpServletSseServerTransportProvider.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -232,7 +232,8 @@ public Mono<Void> notifyClients(String method, Object params) {
232232
public Mono<Void> notifyClient(String sessionId, String method, Object params) {
233233
return Mono.defer(() -> {
234234
// Need to iterate in O(n) because the transport session id
235-
// is different from the server-logical session id
235+
// is different from the server-logical session id (in streamable http this
236+
// design issue was solved)
236237
McpServerSession session = sessions.values()
237238
.stream()
238239
.filter(s -> sessionId.equals(s.getId()))

mcp-test/src/test/java/io/modelcontextprotocol/server/ResourceSubscriptionTests.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,6 @@
1919
* Unit tests for resource subscription logic in {@link McpAsyncServer}. Uses
2020
* {@link MockMcpServerTransportProvider} to drive sessions directly without a real
2121
* network stack.
22-
*
23-
* <p>
24-
* Each test creates a transport with a response-interceptor latch so that
25-
* {@code simulateIncomingMessage} (fire-and-forget) can be reliably awaited before
26-
* asserting subscription state.
2722
*/
2823
class ResourceSubscriptionTests {
2924

0 commit comments

Comments
 (0)