Package org.springaicommunity.mcp.context

Class DefaultMcpAsyncRequestContext

java.lang.Object

org.springaicommunity.mcp.context.DefaultMcpAsyncRequestContext

All Implemented Interfaces:

McpAsyncRequestContext, McpRequestContextTypes<io.modelcontextprotocol.server.McpAsyncServerExchange>

public class DefaultMcpAsyncRequestContext
extends Object
implements McpAsyncRequestContext

Async (Reactor) implementation of McpAsyncRequestContext that returns Mono of value types.

Author:

Christian Tzolov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultMcpAsyncRequestContext.Builder

Nested classes/interfaces inherited from interface org.springaicommunity.mcp.context.McpRequestContextTypes

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

Method Summary

Modifier and Type	Method	Description
static DefaultMcpAsyncRequestContext.Builder	builder()
io.modelcontextprotocol.spec.McpSchema.ClientCapabilities	clientCapabilities()
io.modelcontextprotocol.spec.McpSchema.Implementation	clientInfo()
reactor.core.publisher.Mono<Void>	debug(String message)
<T> reactor.core.publisher.Mono<StructuredElicitResult<T>>	elicit(com.fasterxml.jackson.core.type.TypeReference<T> type)
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, com.fasterxml.jackson.core.type.TypeReference<T> type)
<T> reactor.core.publisher.Mono<StructuredElicitResult<T>>	elicit(Consumer<McpRequestContextTypes.ElicitationSpec> spec, Class<T> type)
reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.ElicitResult>	elicitationInternal(String message, Type type, Map<String,Object> meta)
reactor.core.publisher.Mono<Boolean>	elicitEnabled()
reactor.core.publisher.Mono<Void>	error(String message)
io.modelcontextprotocol.server.McpAsyncServerExchange	exchange()
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 percentage)
reactor.core.publisher.Mono<Void>	progress(io.modelcontextprotocol.spec.McpSchema.ProgressNotification progressNotification)
reactor.core.publisher.Mono<Void>	progress(Consumer<McpRequestContextTypes.ProgressSpec> progressSpec)
io.modelcontextprotocol.spec.McpSchema.Request	request()
Map<String,Object>	requestMeta()
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()
String	sessionId()
io.modelcontextprotocol.common.McpTransportContext	transportContext()
reactor.core.publisher.Mono<Void>	warn(String message)

Methods inherited from class java.lang.Object

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

Method Details

rootsEnabled

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

Specified by:

rootsEnabled in interface McpAsyncRequestContext

roots

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

Specified by:

roots in interface McpAsyncRequestContext

elicitEnabled

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

Specified by:

elicitEnabled in interface McpAsyncRequestContext

elicit

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

Specified by:

elicit in interface McpAsyncRequestContext

elicit

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

Specified by:

elicit in interface McpAsyncRequestContext

elicit

public <T>
reactor.core.publisher.Mono<StructuredElicitResult<T>> elicit(com.fasterxml.jackson.core.type.TypeReference<T> type)

Specified by:

elicit in interface McpAsyncRequestContext

elicit

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

Specified by:

elicit in interface McpAsyncRequestContext

elicit

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

Specified by:

elicit in interface McpAsyncRequestContext

elicitationInternal

public reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.ElicitResult> elicitationInternal(String message,
 Type type,
 Map<String,Object> meta)

sampleEnabled

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

Specified by:

sampleEnabled in interface McpAsyncRequestContext

sample

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

Specified by:

sample in interface McpAsyncRequestContext

sample

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

Specified by:

sample in interface McpAsyncRequestContext

sample

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

Specified by:

sample in interface McpAsyncRequestContext

progress

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

Specified by:

progress in interface McpAsyncRequestContext

progress

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

Specified by:

progress in interface McpAsyncRequestContext

progress

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

Specified by:

progress in interface McpAsyncRequestContext

ping

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

Specified by:

ping in interface McpAsyncRequestContext

log

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

Specified by:

log in interface McpAsyncRequestContext

debug

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

Specified by:

debug in interface McpAsyncRequestContext

info

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

Specified by:

info in interface McpAsyncRequestContext

warn

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

Specified by:

warn in interface McpAsyncRequestContext

error

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

Specified by:

error in interface McpAsyncRequestContext

request

public io.modelcontextprotocol.spec.McpSchema.Request request()

Specified by:

request in interface McpRequestContextTypes<io.modelcontextprotocol.server.McpAsyncServerExchange>

exchange

public io.modelcontextprotocol.server.McpAsyncServerExchange exchange()

Specified by:

exchange in interface McpRequestContextTypes<io.modelcontextprotocol.server.McpAsyncServerExchange>

sessionId

public String sessionId()

Specified by:

sessionId in interface McpRequestContextTypes<io.modelcontextprotocol.server.McpAsyncServerExchange>

clientInfo

public io.modelcontextprotocol.spec.McpSchema.Implementation clientInfo()

Specified by:

clientInfo in interface McpRequestContextTypes<io.modelcontextprotocol.server.McpAsyncServerExchange>

clientCapabilities

public io.modelcontextprotocol.spec.McpSchema.ClientCapabilities clientCapabilities()

Specified by:

clientCapabilities in interface McpRequestContextTypes<io.modelcontextprotocol.server.McpAsyncServerExchange>

requestMeta

public Map<String,Object> requestMeta()

Specified by:

requestMeta in interface McpRequestContextTypes<io.modelcontextprotocol.server.McpAsyncServerExchange>

transportContext

public io.modelcontextprotocol.common.McpTransportContext transportContext()

Specified by:

transportContext in interface McpRequestContextTypes<io.modelcontextprotocol.server.McpAsyncServerExchange>

builder

public static DefaultMcpAsyncRequestContext.Builder builder()