temp fix for void mapping returning null

chemicL · chemicL · commit 51e9c98520ea · 2024-12-09T12:46:51.000+01:00
diff --git 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 <T> Mono<T> sendRequest(String method, Object requestParams, TypeReferenc
 					   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));
+						   }
 					   }
 		           });
 	}

Original file line number	Diff line number	Diff line change
`@@ -80,7 +80,12 @@ public <T> Mono<T> sendRequest(String method, Object requestParams, TypeReferenc`
`80`	`80`	`if (jsonRpcResponse.error() != null) {`
`81`	`81`	`s.error(new McpError(jsonRpcResponse.error()));`
`82`	`82`	`} else {`
`83`		`- s.next(this.objectMapper.convertValue(jsonRpcResponse.result(), typeRef));`
	`83`	`+ if (typeRef.getType().getTypeName().equals("java.lang.Void")) {`
	`84`	`+ s.complete();`
	`85`	`+ } else {`
	`86`	`+ s.next(this.objectMapper.convertValue(jsonRpcResponse.result(),`
	`87`	`+ typeRef));`
	`88`	`+ }`
`84`	`89`	`}`
`85`	`90`	`});`
`86`	`91`	`}`