diff --git a/mcp/src/main/java/io/modelcontextprotocol/spec/McpTransport.java b/mcp/src/main/java/io/modelcontextprotocol/spec/McpTransport.java index 40d9ba7ac..0f2c007dc 100644 --- a/mcp/src/main/java/io/modelcontextprotocol/spec/McpTransport.java +++ b/mcp/src/main/java/io/modelcontextprotocol/spec/McpTransport.java @@ -46,7 +46,7 @@ public interface McpTransport { *

*/ default void close() { - this.closeGracefully().subscribe(); + this.closeGracefully().block(); } /**