Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion mcp-spring/mcp-spring-webflux/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ static class MyConfig {
// Router function for SSE transport used by Spring WebFlux to start an HTTP
// server.
@Bean
public RouterFunction<?> mcpRouterFunction(WebFluxSseServerTransport transport) {
public RouterFunction<ServerResponse> mcpRouterFunction(WebFluxSseServerTransport transport) {
return transport.getRouterFunction();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,7 @@ public class WebFluxSseServerTransportProvider implements McpServerTransportProv

private final String sseEndpoint;

private final RouterFunction<?> routerFunction;
private final RouterFunction<ServerResponse> routerFunction;

private McpServerSession.Factory sessionFactory;

Expand Down Expand Up @@ -256,7 +256,7 @@ public Mono<Void> closeGracefully() {
* </ul>
* @return The configured {@link RouterFunction} for handling HTTP requests
*/
public RouterFunction<?> getRouterFunction() {
public RouterFunction<ServerResponse> getRouterFunction() {
return this.routerFunction;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ public class WebFluxStatelessServerTransport implements McpStatelessServerTransp

private final String mcpEndpoint;

private final RouterFunction<?> routerFunction;
private final RouterFunction<ServerResponse> routerFunction;

private McpStatelessServerHandler mcpHandler;

Expand Down Expand Up @@ -83,7 +83,7 @@ public Mono<Void> closeGracefully() {
* </ul>
* @return The configured {@link RouterFunction} for handling HTTP requests
*/
public RouterFunction<?> getRouterFunction() {
public RouterFunction<ServerResponse> getRouterFunction() {
return this.routerFunction;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ public class WebFluxStreamableServerTransportProvider implements McpStreamableSe

private final boolean disallowDelete;

private final RouterFunction<?> routerFunction;
private final RouterFunction<ServerResponse> routerFunction;

private McpStreamableServerSession.Factory sessionFactory;

Expand Down Expand Up @@ -152,7 +152,7 @@ public Mono<Void> closeGracefully() {
* </ul>
* @return The configured {@link RouterFunction} for handling HTTP requests
*/
public RouterFunction<?> getRouterFunction() {
public RouterFunction<ServerResponse> getRouterFunction() {
return this.routerFunction;
}

Expand Down
Loading