io.modelcontextprotocol.spec

类 DefaultMcpTransportStream<CONNECTION>

java.lang.Object

io.modelcontextprotocol.spec.DefaultMcpTransportStream<CONNECTION>

类型参数:

CONNECTION - the resource serving the stream

所有已实现的接口:

McpTransportStream<CONNECTION>

public class DefaultMcpTransportStream<CONNECTION>
extends java.lang.Object
implements McpTransportStream<CONNECTION>

An implementation of McpTransportStream using Project Reactor types.

构造器概要

构造器

构造器和说明
DefaultMcpTransportStream(boolean resumable, java.util.function.Function<McpTransportStream<CONNECTION>,org.reactivestreams.Publisher<CONNECTION>> reconnect) Constructs a new instance representing a particular stream that can resume using the provided reconnect mechanism.

方法概要

限定符和类型	方法和说明
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.

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

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

构造器详细资料

DefaultMcpTransportStream

public DefaultMcpTransportStream(boolean resumable,
                                 java.util.function.Function<McpTransportStream<CONNECTION>,org.reactivestreams.Publisher<CONNECTION>> reconnect)

Constructs a new instance representing a particular stream that can resume using the provided reconnect mechanism.

参数:

resumable - whether the stream is resumable and should try to reconnect

reconnect - the mechanism to use in case an error is observed on the current event stream to asynchronously kick off a resumed stream consumption, potentially using the stored lastId().

方法详细资料

lastId

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

从接口复制的说明: McpTransportStream

The last observed event identifier.

指定者:

lastId 在接口中 McpTransportStream<CONNECTION>

返回:

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

streamId

public long streamId()

从接口复制的说明: McpTransportStream

An internal stream identifier used to distinguish streams while debugging.

指定者:

streamId 在接口中 McpTransportStream<CONNECTION>

返回:

a long stream identifier value

consumeSseStream

public 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)

从接口复制的说明: McpTransportStream

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.

指定者:

consumeSseStream 在接口中 McpTransportStream<CONNECTION>

参数:

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