Struct RequestRouter 

pub struct RequestRouter { /* private fields */ }

Request router for dispatching MCP requests to appropriate handlers

Implementations

impl RequestRouter

pub fn new(registry: Arc<HandlerRegistry>, _metrics: Arc<ServerMetrics>) -> Self

Create a new request router

pub fn with_config( registry: Arc<HandlerRegistry>, config: RouterConfig, _metrics: Arc<ServerMetrics>, ) -> Self

Create a router with configuration

pub fn set_server_request_dispatcher<D>(&mut self, dispatcher: D)

where D: ServerRequestDispatcher + 'static,

Set the server request dispatcher for bidirectional communication

pub fn get_server_request_dispatcher( &self, ) -> Option<&Arc<dyn ServerRequestDispatcher>>

Get the server request dispatcher

pub fn supports_bidirectional(&self) -> bool

Check if bidirectional routing is enabled and supported

pub fn add_route<H>(&mut self, handler: H) -> ServerResult<()>

where H: RouteHandler + 'static,

Add a custom route handler

Errors

Returns ServerError::Routing if a route for the same method already exists.

pub async fn route( &self, request: JsonRpcRequest, ctx: RequestContext, ) -> JsonRpcResponse

Route a JSON-RPC request to the appropriate handler

pub async fn route_batch( &self, requests: Vec<JsonRpcRequest>, ctx: RequestContext, ) -> Vec<JsonRpcResponse>

Handle batch requests

pub async fn send_elicitation_to_client( &self, request: ElicitRequest, ctx: RequestContext, ) -> ServerResult<ElicitResult>

Send an elicitation request to the client (server-initiated)

Errors

Returns ServerError::Transport if:

• The bidirectional dispatcher is not configured
• The client request fails
• The client does not respond

pub async fn send_ping_to_client( &self, request: PingRequest, ctx: RequestContext, ) -> ServerResult<PingResult>

Send a ping request to the client (server-initiated)

Errors

Returns ServerError::Transport if:

• The bidirectional dispatcher is not configured
• The client request fails
• The client does not respond

pub async fn send_create_message_to_client( &self, request: CreateMessageRequest, ctx: RequestContext, ) -> ServerResult<CreateMessageResult>

Send a create message request to the client (server-initiated)

Errors

Returns ServerError::Transport if:

• The bidirectional dispatcher is not configured
• The client request fails
• The client does not support sampling

pub async fn send_list_roots_to_client( &self, request: ListRootsRequest, ctx: RequestContext, ) -> ServerResult<ListRootsResult>

Send a list roots request to the client (server-initiated)

Errors

Returns ServerError::Transport if:

• The bidirectional dispatcher is not configured
• The client request fails
• The client does not support roots

Trait Implementations

impl Clone for RequestRouter

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RequestRouter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl JsonRpcHandler for RequestRouter

fn handle_request<'life0, 'async_trait>( &'life0 self, req_value: Value, ) -> Pin<Box<dyn Future<Output = Value> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle a JSON-RPC request via the HTTP transport

This implementation enables RequestRouter to be used directly with the HTTP transport layer (run_server), supporting the builder pattern for programmatic server construction.

Architecture

• Parses raw JSON into JsonRpcRequest
• Creates default RequestContext (no auth/session for HTTP)
• Routes through the existing route() method
• Serializes JsonRpcResponse back to JSON

This provides the same request handling as the macro pattern but allows runtime handler registration via ServerBuilder.

fn server_info(&self) -> ServerInfo

Get server metadata

fn capabilities(&self) -> Value

Get server capabilities