Package org.springframework.ai.mcp.annotation.context

Interface McpAsyncRequestContext

All Superinterfaces:

McpRequestContextTypes<io.modelcontextprotocol.server.McpAsyncServerExchange>

All Known Implementing Classes:

DefaultMcpAsyncRequestContext

public interface McpAsyncRequestContext
extends McpRequestContextTypes<io.modelcontextprotocol.server.McpAsyncServerExchange>

Async (Reactor) version of McpSyncRequestContext that returns Mono of value types.

Author:

Christian Tzolov

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.ai.mcp.annotation.context.McpRequestContextTypes

McpRequestContextTypes.ElicitationSpec, McpRequestContextTypes.LoggingSpec, McpRequestContextTypes.ModelPreferenceSpec, McpRequestContextTypes.ProgressSpec, McpRequestContextTypes.SamplingSpec

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<Void>	debug(String message)
reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.ElicitResult>	elicit(io.modelcontextprotocol.spec.McpSchema.ElicitRequest elicitRequest)
<T> reactor.core.publisher.Mono<StructuredElicitResult<T>>	elicit(Class<T> type)
<T> reactor.core.publisher.Mono<StructuredElicitResult<T>>	elicit(Consumer<McpRequestContextTypes.ElicitationSpec> spec, Class<T> returnType)
<T> reactor.core.publisher.Mono<StructuredElicitResult<T>>	elicit(Consumer<McpRequestContextTypes.ElicitationSpec> spec, tools.jackson.core.type.TypeReference<T> returnType)
<T> reactor.core.publisher.Mono<StructuredElicitResult<T>>	elicit(tools.jackson.core.type.TypeReference<T> type)
reactor.core.publisher.Mono<Boolean>	elicitEnabled()
reactor.core.publisher.Mono<Void>	error(String message)
reactor.core.publisher.Mono<Void>	info(String message)
reactor.core.publisher.Mono<Void>	log(Consumer<McpRequestContextTypes.LoggingSpec> logSpec)
reactor.core.publisher.Mono<Object>	ping()
reactor.core.publisher.Mono<Void>	progress(int progress)
reactor.core.publisher.Mono<Void>	progress(io.modelcontextprotocol.spec.McpSchema.ProgressNotification progressNotification)
reactor.core.publisher.Mono<Void>	progress(Consumer<McpRequestContextTypes.ProgressSpec> progressSpec)
reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.ListRootsResult>	roots()
reactor.core.publisher.Mono<Boolean>	rootsEnabled()
reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.CreateMessageResult>	sample(io.modelcontextprotocol.spec.McpSchema.CreateMessageRequest createMessageRequest)
reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.CreateMessageResult>	sample(String... messages)
reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.CreateMessageResult>	sample(Consumer<McpRequestContextTypes.SamplingSpec> samplingSpec)
reactor.core.publisher.Mono<Boolean>	sampleEnabled()
reactor.core.publisher.Mono<Void>	warn(String message)

Methods inherited from interface org.springframework.ai.mcp.annotation.context.McpRequestContextTypes

clientCapabilities, clientInfo, exchange, request, requestMeta, sessionId, transportContext

Method Details

rootsEnabled

reactor.core.publisher.Mono<Boolean> rootsEnabled()

roots

reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.ListRootsResult> roots()

elicitEnabled

reactor.core.publisher.Mono<Boolean> elicitEnabled()

elicit

<T>
reactor.core.publisher.Mono<StructuredElicitResult<T>> elicit(Class<T> type)

elicit

<T>
reactor.core.publisher.Mono<StructuredElicitResult<T>> elicit(tools.jackson.core.type.TypeReference<T> type)

elicit

<T>
reactor.core.publisher.Mono<StructuredElicitResult<T>> elicit(Consumer<McpRequestContextTypes.ElicitationSpec> spec,
 tools.jackson.core.type.TypeReference<T> returnType)

elicit

<T>
reactor.core.publisher.Mono<StructuredElicitResult<T>> elicit(Consumer<McpRequestContextTypes.ElicitationSpec> spec,
 Class<T> returnType)

elicit

reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.ElicitResult> elicit(io.modelcontextprotocol.spec.McpSchema.ElicitRequest elicitRequest)

sampleEnabled

reactor.core.publisher.Mono<Boolean> sampleEnabled()

sample

reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.CreateMessageResult> sample(String... messages)

sample

reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.CreateMessageResult> sample(Consumer<McpRequestContextTypes.SamplingSpec> samplingSpec)

sample

reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.CreateMessageResult> sample(io.modelcontextprotocol.spec.McpSchema.CreateMessageRequest createMessageRequest)

progress

reactor.core.publisher.Mono<Void> progress(int progress)

progress

reactor.core.publisher.Mono<Void> progress(Consumer<McpRequestContextTypes.ProgressSpec> progressSpec)

progress

reactor.core.publisher.Mono<Void> progress(io.modelcontextprotocol.spec.McpSchema.ProgressNotification progressNotification)

ping

reactor.core.publisher.Mono<Object> ping()

log

reactor.core.publisher.Mono<Void> log(Consumer<McpRequestContextTypes.LoggingSpec> logSpec)

debug

reactor.core.publisher.Mono<Void> debug(String message)

info

reactor.core.publisher.Mono<Void> info(String message)

warn

reactor.core.publisher.Mono<Void> warn(String message)

error

reactor.core.publisher.Mono<Void> error(String message)