Package org.springaicommunity.mcp.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

  • 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(com.fasterxml.jackson.core.type.TypeReference<T> type)

    • elicit

      <T> reactor.core.publisher.Mono<StructuredElicitResult<T>> elicit(Consumer<McpRequestContextTypes.ElicitationSpec> spec, com.fasterxml.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)