Struct JsonRpcDispatcher 

pub struct JsonRpcDispatcher<'a> { /* private fields */ }

JSON-RPC 2.0 dispatcher for MCP stdio transport.

Implementations

impl<'a> JsonRpcDispatcher<'a>

pub fn new(server: &'a McpServer) -> Self

Create a new dispatcher wrapping an MCP server.

pub fn dispatch_authenticated( &self, request: &str, auth_header: Option<&str>, ) -> Option<String>

Dispatch a request, checking the Authorization header if auth is configured.

Returns a JSON-RPC -32001 error response when auth fails. Pass None for auth_header when no header is present (stdio transport).

pub fn dispatch(&self, request: &str) -> Option<String>

Dispatch a JSON-RPC request (single or batch) and return the response.

pub async fn dispatch_async(&self, request: &str) -> Option<String>

Dispatch a JSON-RPC request, awaiting async tool handlers.

Identical to JsonRpcDispatcher::dispatch except that tools/call resolves through McpServer::call_tool_async, so tools registered with set_async_handler work. The synchronous Self::dispatch cannot invoke them — prefer this one whenever the server has any async handler.

pub async fn dispatch_authenticated_async( &self, request: &str, auth_header: Option<&str>, ) -> Option<String>

Self::dispatch_authenticated with async tool handler support.

pub fn run_stdio(&self) -> Result<()>

Run the stdio transport loop: read lines from stdin, dispatch, write to stdout.

Tools registered with set_async_handler are NOT callable from this loop — use Self::run_stdio_async when the server has any.

Errors

Fails immediately (InvalidInput) when the server has any async-only tool: every call to it would otherwise return isError at runtime and look like a handler bug.

pub async fn run_stdio_async(&self) -> Result<()>

Self::run_stdio for servers with async tool handlers.

Reads stdin with blocking I/O between awaits — an MCP stdio server is a dedicated process, so occupying the calling task is intended. Drive it from a runtime’s blocking-friendly context (e.g. a dedicated task).