McpProtocol
class McpProtocol<Transport>(sessions: Sessions<Transport>, initializer: Initializer, tools: Tools = tools(), resources: Resources = resources(), prompts: Prompts = prompts(), completions: Completions = completions(), logger: Logger = logger(), roots: Roots = roots(), cancellations: Cancellations = cancellations(), tasks: Tasks = tasks(), mcpFilter: McpFilter = McpFilter.NoOp, onError: (Throwable) -> Unit = { it.printStackTrace(System.err) }, random: Random = SecureRandom())(source)
Models the MCP protocol in terms of message handling and session management.
Constructors
Link copied to clipboard
constructor(sessions: Sessions<Transport>, initializer: Initializer, tools: Tools = tools(), resources: Resources = resources(), prompts: Prompts = prompts(), completions: Completions = completions(), logger: Logger = logger(), roots: Roots = roots(), cancellations: Cancellations = cancellations(), tasks: Tasks = tasks(), mcpFilter: McpFilter = McpFilter.NoOp, onError: (Throwable) -> Unit = { it.printStackTrace(System.err) }, random: Random = SecureRandom())
constructor(metaData: ServerMetaData, sessions: Sessions<Transport>, mcpFilter: McpFilter = McpFilter.NoOp, vararg capabilities: ServerCapability)
constructor(initializeHandler: InitializeHandler, sessions: Sessions<Transport>, mcpFilter: McpFilter = McpFilter.NoOp, vararg capabilities: ServerCapability)
Functions
Link copied to clipboard
fun receive(transport: Transport, sessionState: McpSessionState.Valid, httpReq: Request): McpResponse
Link copied to clipboard
Link copied to clipboard
fun subscribe(context: ClientRequestContext.Subscription, transport: Transport, connectRequest: Request)
Link copied to clipboard
Link copied to clipboard