|  | 
| 28 | 28 | import io.modelcontextprotocol.server.McpServer.AsyncSpecification; | 
| 29 | 29 | import io.modelcontextprotocol.server.McpServer.SyncSpecification; | 
| 30 | 30 | import io.modelcontextprotocol.server.McpServerFeatures; | 
| 31 |  | -import io.modelcontextprotocol.server.McpServerFeatures.AsyncCompletionSpecification; | 
|  | 31 | +// import io.modelcontextprotocol.server.McpServerFeatures.AsyncCompletionSpecification; | 
| 32 | 32 | import io.modelcontextprotocol.server.McpServerFeatures.AsyncPromptSpecification; | 
| 33 | 33 | import io.modelcontextprotocol.server.McpServerFeatures.AsyncResourceSpecification; | 
| 34 | 34 | import io.modelcontextprotocol.server.McpServerFeatures.AsyncToolSpecification; | 
| 35 |  | -import io.modelcontextprotocol.server.McpServerFeatures.SyncCompletionSpecification; | 
|  | 35 | +// import io.modelcontextprotocol.server.McpServerFeatures.SyncCompletionSpecification; | 
| 36 | 36 | import io.modelcontextprotocol.server.McpServerFeatures.SyncPromptSpecification; | 
| 37 | 37 | import io.modelcontextprotocol.server.McpServerFeatures.SyncResourceSpecification; | 
| 38 | 38 | import io.modelcontextprotocol.server.McpServerFeatures.SyncToolSpecification; | 
| @@ -175,7 +175,7 @@ public McpSyncServer mcpSyncServer(McpServerTransportProvider transportProvider, | 
| 175 | 175 | 			ObjectProvider<List<SyncToolSpecification>> tools, | 
| 176 | 176 | 			ObjectProvider<List<SyncResourceSpecification>> resources, | 
| 177 | 177 | 			ObjectProvider<List<SyncPromptSpecification>> prompts, | 
| 178 |  | -			ObjectProvider<List<SyncCompletionSpecification>> completions, | 
|  | 178 | +			// ObjectProvider<List<SyncCompletionSpecification>> completions, | 
| 179 | 179 | 			ObjectProvider<BiConsumer<McpSyncServerExchange, List<McpSchema.Root>>> rootsChangeConsumers, | 
| 180 | 180 | 			List<ToolCallbackProvider> toolCallbackProvider) { | 
| 181 | 181 | 
 | 
| @@ -219,14 +219,15 @@ public McpSyncServer mcpSyncServer(McpServerTransportProvider transportProvider, | 
| 219 | 219 | 					+ serverProperties.isPromptChangeNotification()); | 
| 220 | 220 | 		} | 
| 221 | 221 | 
 | 
| 222 |  | -		List<SyncCompletionSpecification> completionSpecifications = completions.stream() | 
| 223 |  | -			.flatMap(List::stream) | 
| 224 |  | -			.toList(); | 
| 225 |  | -		if (!CollectionUtils.isEmpty(completionSpecifications)) { | 
| 226 |  | -			serverBuilder.completions(completionSpecifications); | 
| 227 |  | -			capabilitiesBuilder.completions(); | 
| 228 |  | -			logger.info("Registered completions: " + completionSpecifications.size()); | 
| 229 |  | -		} | 
|  | 222 | +		// List<SyncCompletionSpecification> completionSpecifications = | 
|  | 223 | +		// completions.stream() | 
|  | 224 | +		// .flatMap(List::stream) | 
|  | 225 | +		// .toList(); | 
|  | 226 | +		// if (!CollectionUtils.isEmpty(completionSpecifications)) { | 
|  | 227 | +		// serverBuilder.completions(completionSpecifications); | 
|  | 228 | +		// capabilitiesBuilder.completions(); | 
|  | 229 | +		// logger.info("Registered completions: " + completionSpecifications.size()); | 
|  | 230 | +		// } | 
| 230 | 231 | 
 | 
| 231 | 232 | 		rootsChangeConsumers.ifAvailable(consumer -> { | 
| 232 | 233 | 			serverBuilder.rootsChangeHandler((exchange, roots) -> consumer.accept(exchange, roots)); | 
| @@ -282,7 +283,7 @@ public McpAsyncServer mcpAsyncServer(McpServerTransportProvider transportProvide | 
| 282 | 283 | 			ObjectProvider<List<AsyncToolSpecification>> tools, | 
| 283 | 284 | 			ObjectProvider<List<AsyncResourceSpecification>> resources, | 
| 284 | 285 | 			ObjectProvider<List<AsyncPromptSpecification>> prompts, | 
| 285 |  | -			ObjectProvider<List<AsyncCompletionSpecification>> completions, | 
|  | 286 | +			// ObjectProvider<List<AsyncCompletionSpecification>> completions, | 
| 286 | 287 | 			ObjectProvider<BiConsumer<McpAsyncServerExchange, List<McpSchema.Root>>> rootsChangeConsumer, | 
| 287 | 288 | 			List<ToolCallbackProvider> toolCallbackProvider) { | 
| 288 | 289 | 
 | 
| @@ -326,14 +327,15 @@ public McpAsyncServer mcpAsyncServer(McpServerTransportProvider transportProvide | 
| 326 | 327 | 					+ serverProperties.isPromptChangeNotification()); | 
| 327 | 328 | 		} | 
| 328 | 329 | 
 | 
| 329 |  | -		List<AsyncCompletionSpecification> completionSpecifications = completions.stream() | 
| 330 |  | -			.flatMap(List::stream) | 
| 331 |  | -			.toList(); | 
| 332 |  | -		if (!CollectionUtils.isEmpty(completionSpecifications)) { | 
| 333 |  | -			serverBuilder.completions(completionSpecifications); | 
| 334 |  | -			capabilitiesBuilder.completions(); | 
| 335 |  | -			logger.info("Registered completions: " + completionSpecifications.size()); | 
| 336 |  | -		} | 
|  | 330 | +		// List<AsyncCompletionSpecification> completionSpecifications = | 
|  | 331 | +		// completions.stream() | 
|  | 332 | +		// .flatMap(List::stream) | 
|  | 333 | +		// .toList(); | 
|  | 334 | +		// if (!CollectionUtils.isEmpty(completionSpecifications)) { | 
|  | 335 | +		// serverBuilder.completions(completionSpecifications); | 
|  | 336 | +		// capabilitiesBuilder.completions(); | 
|  | 337 | +		// logger.info("Registered completions: " + completionSpecifications.size()); | 
|  | 338 | +		// } | 
| 337 | 339 | 
 | 
| 338 | 340 | 		rootsChangeConsumer.ifAvailable(consumer -> { | 
| 339 | 341 | 			BiFunction<McpAsyncServerExchange, List<McpSchema.Root>, Mono<Void>> asyncConsumer = (exchange, roots) -> { | 
|  | 
0 commit comments