|
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