Struct SessionMcpHandler 

pub struct SessionMcpHandler { /* private fields */ }

JSON-RPC 2.0 over HTTP handler with shared StreamManager

Implementations

impl SessionMcpHandler

pub fn new( config: ServerConfig, dispatcher: Arc<JsonRpcDispatcher<McpError>>, stream_config: StreamConfig, ) -> Self

Create a new handler with default in-memory storage (zero-configuration)

pub fn with_shared_stream_manager( config: ServerConfig, dispatcher: Arc<JsonRpcDispatcher<McpError>>, session_storage: Arc<BoxedSessionStorage>, stream_config: StreamConfig, stream_manager: Arc<StreamManager>, ) -> Self

Create handler with shared StreamManager instance (corrected architecture)

pub fn with_storage( config: ServerConfig, dispatcher: Arc<JsonRpcDispatcher<McpError>>, session_storage: Arc<BoxedSessionStorage>, stream_config: StreamConfig, ) -> Self

Create handler with specific session storage backend (creates own StreamManager) Note: Use with_shared_stream_manager for correct architecture

pub fn get_stream_manager(&self) -> &Arc<StreamManager>

Get access to the StreamManager for notifications

pub async fn handle_mcp_request<B>( &self, req: Request<B>, ) -> Result<Response<UnsyncBoxBody<Bytes, Error>>>

where B: Body<Data = Bytes, Error = Error> + Send + 'static,

Handle MCP HTTP requests with full MCP 2025-06-18 compliance

Trait Implementations

impl Clone for SessionMcpHandler

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.