io.modelcontextprotocol.server.transport

类 WebRxSseServerTransportProvider.WebRxMcpSessionTransport

java.lang.Object

io.modelcontextprotocol.server.transport.WebRxSseServerTransportProvider.WebRxMcpSessionTransport

所有已实现的接口:

McpServerTransport, McpTransport

封闭类:

WebRxSseServerTransportProvider

public class WebRxSseServerTransportProvider.WebRxMcpSessionTransport
extends java.lang.Object
implements McpServerTransport

构造器概要

构造器

构造器和说明
WebRxMcpSessionTransport(org.noear.solon.core.handle.Context context, reactor.core.publisher.FluxSink<org.noear.solon.web.sse.SseEvent> sink)

方法概要

限定符和类型	方法和说明
void	close() Closes the transport connection and releases any associated resources.
reactor.core.publisher.Mono<java.lang.Void>	closeGracefully() Closes the transport connection and releases any associated resources asynchronously.
org.noear.solon.core.handle.Context	getContext()
void	sendHeartbeat()
reactor.core.publisher.Mono<java.lang.Void>	sendMessage(McpSchema.JSONRPCMessage message) Sends a message to the peer asynchronously.
<T> T	unmarshalFrom(java.lang.Object data, com.fasterxml.jackson.core.type.TypeReference<T> typeRef) Unmarshals the given data into an object of the specified type.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 io.modelcontextprotocol.spec.McpTransport

connect

构造器详细资料

WebRxMcpSessionTransport

public WebRxMcpSessionTransport(org.noear.solon.core.handle.Context context,
                                reactor.core.publisher.FluxSink<org.noear.solon.web.sse.SseEvent> sink)

方法详细资料

getContext

public org.noear.solon.core.handle.Context getContext()

sendHeartbeat

public void sendHeartbeat()

sendMessage

public reactor.core.publisher.Mono<java.lang.Void> sendMessage(McpSchema.JSONRPCMessage message)

从接口复制的说明: McpTransport

Sends a message to the peer asynchronously.

This method handles the transmission of messages to the server in an asynchronous manner. Messages are sent in JSON-RPC format as specified by the MCP protocol.

指定者:

sendMessage 在接口中 McpTransport

参数:

message - the McpSchema.JSONRPCMessage to be sent to the server

返回:

a Mono that completes when the message has been sent

unmarshalFrom

public <T> T unmarshalFrom(java.lang.Object data,
                           com.fasterxml.jackson.core.type.TypeReference<T> typeRef)

从接口复制的说明: McpTransport

Unmarshals the given data into an object of the specified type.

指定者:

unmarshalFrom 在接口中 McpTransport

类型参数:

T - the type of the object to unmarshal

参数:

data - the data to unmarshal

typeRef - the type reference for the object to unmarshal

返回:

the unmarshalled object

closeGracefully

public reactor.core.publisher.Mono<java.lang.Void> closeGracefully()

从接口复制的说明: McpTransport

Closes the transport connection and releases any associated resources asynchronously.

指定者:

closeGracefully 在接口中 McpTransport

返回:

a Mono that completes when the connection has been closed.

close

public void close()

从接口复制的说明: McpTransport

Closes the transport connection and releases any associated resources.

This method ensures proper cleanup of resources when the transport is no longer needed. It should handle the graceful shutdown of any active connections.

指定者:

close 在接口中 McpTransport