Skip to content

Commit 29d9e3c

Browse files
committed
fix(server): Mono.subscribe() should be called explicitly
1 parent ce240f6 commit 29d9e3c

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

src/main/java/com/github/codeboyzhou/mcp/declarative/server/factory/McpServerPromptFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ public void registerTo(McpAsyncServer server) {
7373
queue.submit(prompt);
7474
}
7575
}
76-
queue.consume(server::addPrompt);
76+
queue.consume(prompt -> server.addPrompt(prompt).subscribe());
7777
}
7878

7979
private List<McpSchema.PromptArgument> createPromptArguments(Method method) {

src/main/java/com/github/codeboyzhou/mcp/declarative/server/factory/McpServerResourceFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ public void registerTo(McpAsyncServer server) {
6666
queue.submit(resource);
6767
}
6868
}
69-
queue.consume(server::addResource);
69+
queue.consume(resource -> server.addResource(resource).subscribe());
7070
}
7171

7272
}

src/main/java/com/github/codeboyzhou/mcp/declarative/server/factory/McpServerToolFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ public void registerTo(McpAsyncServer server) {
8080
queue.submit(tool);
8181
}
8282
}
83-
queue.consume(server::addTool);
83+
queue.consume(tool -> server.addTool(tool).subscribe());
8484
}
8585

8686
private McpSchema.JsonSchema createJsonSchema(Method method) {

0 commit comments

Comments
 (0)