functional style

Author: sdelamo

mcp-core/src/main/java/io/modelcontextprotocol/server/McpAsyncServer.java

@@ -645,13 +645,10 @@ private McpRequestHandler<McpSchema.ReadResourceResult> resourcesReadRequestHand
 					new TypeRef<McpSchema.ReadResourceRequest>() {
 					});
 			var resourceUri = resourceRequest.uri();
-
-			Optional<McpServerFeatures.AsyncResourceSpecification> specification = asyncResourceSpecification(
-					resourceUri);
-			if (specification.isPresent()) {
-				return Mono.error(RESOURCE_NOT_FOUND.apply(resourceUri));
-			}
-			return Mono.defer(() -> specification.get().readHandler().apply(exchange, resourceRequest));
+			return asyncResourceSpecification(resourceUri)
+				.map(asyncResourceSpecification -> Mono
+					.defer(() -> asyncResourceSpecification.readHandler().apply(exchange, resourceRequest)))
+				.orElseGet(() -> Mono.error(RESOURCE_NOT_FOUND.apply(resourceUri)));
 		};
 	}
 

mcp-core/src/main/java/io/modelcontextprotocol/server/McpStatelessAsyncServer.java

@@ -488,7 +488,8 @@ private McpStatelessRequestHandler<McpSchema.ReadResourceResult> resourcesReadRe
 		};
 	}
 
-	private Optional<McpStatelessServerFeatures.AsyncResourceSpecification> asyncResourceSpecification(String resourceUri) {
+	private Optional<McpStatelessServerFeatures.AsyncResourceSpecification> asyncResourceSpecification(
+			String resourceUri) {
 		return resources.values()
 			.stream()
 			.filter(resourceSpecification -> this.uriTemplateManagerFactory