public class StdioServerTransportProvider extends java.lang.Object implements McpServerTransportProvider
构造器和说明 |
---|
StdioServerTransportProvider()
Creates a new StdioServerTransportProvider with a default ObjectMapper and System
streams.
|
StdioServerTransportProvider(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
Creates a new StdioServerTransportProvider with the specified ObjectMapper and
System streams.
|
StdioServerTransportProvider(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
java.io.InputStream inputStream,
java.io.OutputStream outputStream)
Creates a new StdioServerTransportProvider with the specified ObjectMapper and
streams.
|
限定符和类型 | 方法和说明 |
---|---|
reactor.core.publisher.Mono<java.lang.Void> |
closeGracefully()
Gracefully closes all the transports with connected clients and releases any
associated resources asynchronously.
|
reactor.core.publisher.Mono<java.lang.Void> |
notifyClients(java.lang.String method,
java.util.Map<java.lang.String,java.lang.Object> params)
Sends a notification to all connected clients.
|
void |
setSessionFactory(McpServerSession.Factory sessionFactory)
Sets the session factory that will be used to create sessions for new clients.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public StdioServerTransportProvider()
public StdioServerTransportProvider(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
objectMapper
- The ObjectMapper to use for JSON serialization/deserializationpublic StdioServerTransportProvider(com.fasterxml.jackson.databind.ObjectMapper objectMapper, java.io.InputStream inputStream, java.io.OutputStream outputStream)
objectMapper
- The ObjectMapper to use for JSON serialization/deserializationinputStream
- The input stream to read fromoutputStream
- The output stream to write topublic void setSessionFactory(McpServerSession.Factory sessionFactory)
McpServerTransportProvider
setSessionFactory
在接口中 McpServerTransportProvider
sessionFactory
- the session factory to be used for initiating client sessionspublic reactor.core.publisher.Mono<java.lang.Void> notifyClients(java.lang.String method, java.util.Map<java.lang.String,java.lang.Object> params)
McpServerTransportProvider
notifyClients
在接口中 McpServerTransportProvider
method
- the name of the notification method to be called on the clientsparams
- a map of parameters to be sent with the notificationMcpSession.sendNotification(String, Map)
public reactor.core.publisher.Mono<java.lang.Void> closeGracefully()
McpServerTransportProvider
closeGracefully
在接口中 McpServerTransportProvider
Mono
that completes when the connections have been closed.