io.modelcontextprotocol.spec

接口 McpTransportStream<CONNECTION>

类型参数:

CONNECTION - the resource on which the stream is being served and consumed via this mechanism

所有已知实现类:

DefaultMcpTransportStream

public interface McpTransportStream<CONNECTION>

A representation of a stream at the transport layer of the MCP protocol. In particular, it is currently used in the Streamable HTTP implementation to potentially be able to resume a broken connection from where it left off by optionally keeping track of attached SSE event ids.

方法概要

限定符和类型	方法和说明
org.reactivestreams.Publisher<McpSchema.JSONRPCMessage>	consumeSseStream(org.reactivestreams.Publisher<reactor.util.function.Tuple2<java.util.Optional<java.lang.String>,java.lang.Iterable<McpSchema.JSONRPCMessage>>> eventStream) Allows keeping track of the transport stream of events (currently an SSE stream from Streamable HTTP specification) and enable resumability and reconnects in case of stream errors.
java.util.Optional<java.lang.String>	lastId() The last observed event identifier.
long	streamId() An internal stream identifier used to distinguish streams while debugging.

方法详细资料

lastId

java.util.Optional<java.lang.String> lastId()

The last observed event identifier.

返回:

if not empty, contains the most recent event that was consumed

streamId

long streamId()

An internal stream identifier used to distinguish streams while debugging.

返回:

a long stream identifier value

consumeSseStream

org.reactivestreams.Publisher<McpSchema.JSONRPCMessage> consumeSseStream(org.reactivestreams.Publisher<reactor.util.function.Tuple2<java.util.Optional<java.lang.String>,java.lang.Iterable<McpSchema.JSONRPCMessage>>> eventStream)

Allows keeping track of the transport stream of events (currently an SSE stream from Streamable HTTP specification) and enable resumability and reconnects in case of stream errors.

参数:

eventStream - a Publisher of tuples (pairs) of an optional identifier associated with a collection of messages

返回:

a flattened Publisher of JSON-RPC messages with the identifier stripped away