diff --git a/src/main/java/spring/ai/mcp/client/McpAsyncSession.java b/src/main/java/spring/ai/mcp/client/McpAsyncSession.java index 2ee02ad..875516c 100644 --- a/src/main/java/spring/ai/mcp/client/McpAsyncSession.java +++ b/src/main/java/spring/ai/mcp/client/McpAsyncSession.java @@ -80,7 +80,12 @@ public class McpAsyncSession { if (jsonRpcResponse.error() != null) { s.error(new McpError(jsonRpcResponse.error())); } else { - s.next(this.objectMapper.convertValue(jsonRpcResponse.result(), typeRef)); + if (typeRef.getType().getTypeName().equals("java.lang.Void")) { + s.complete(); + } else { + s.next(this.objectMapper.convertValue(jsonRpcResponse.result(), + typeRef)); + } } }); }