Struct LambdaMcpHandler 

pub struct LambdaMcpHandler { /* private fields */ }

Main handler for Lambda MCP requests

This handler processes MCP requests in Lambda by delegating to SessionMcpHandler, eliminating 600+ lines of duplicate business logic code.

Features:

1. Type conversion between lambda_http and hyper
2. Delegation to SessionMcpHandler for all business logic
3. CORS support for browser clients
4. SSE validation to prevent silent failures

Implementations

impl LambdaMcpHandler

pub fn new( dispatcher: JsonRpcDispatcher<McpError>, session_storage: Arc<BoxedSessionStorage>, stream_manager: Arc<StreamManager>, config: ServerConfig, stream_config: StreamConfig, _implementation: Implementation, capabilities: ServerCapabilities, sse_enabled: bool, cors_config: Option<CorsConfig>, ) -> Self

Create a new Lambda MCP handler with the framework components

pub fn with_shared_stream_manager( config: ServerConfig, dispatcher: Arc<JsonRpcDispatcher<McpError>>, session_storage: Arc<BoxedSessionStorage>, stream_manager: Arc<StreamManager>, stream_config: StreamConfig, _implementation: Implementation, capabilities: ServerCapabilities, sse_enabled: bool, ) -> Self

Create with shared stream manager (for advanced use cases)

pub fn with_middleware( config: ServerConfig, dispatcher: Arc<JsonRpcDispatcher<McpError>>, session_storage: Arc<BoxedSessionStorage>, stream_manager: Arc<StreamManager>, stream_config: StreamConfig, capabilities: ServerCapabilities, middleware_stack: Arc<MiddlewareStack>, sse_enabled: bool, ) -> Self

Create with custom middleware stack (for testing and examples)

pub fn with_cors(self, cors_config: CorsConfig) -> Self

Set CORS configuration

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

Get access to the underlying stream manager for notifications

pub async fn handle( &self, req: LambdaRequest, ) -> Result<LambdaResponse<LambdaBody>>

Handle a Lambda HTTP request (snapshot mode - no real-time SSE)

This method performs delegation to SessionMcpHandler for all business logic. It only handles Lambda-specific concerns: CORS and type conversion.

Note: If SSE is enabled (.sse(true)), SSE responses may not stream properly with regular Lambda runtime. For proper SSE streaming, use handle_streaming() with run_with_streaming_response().

pub async fn handle_streaming( &self, req: LambdaRequest, ) -> Result<Response<UnsyncBoxBody<Bytes, Error>>, Box<dyn Error + Send + Sync>>

Handle Lambda streaming request (real SSE streaming)

This method enables real-time SSE streaming using Lambda’s streaming response capability. It delegates all business logic to SessionMcpHandler.

Trait Implementations

impl Clone for LambdaMcpHandler

fn clone(&self) -> LambdaMcpHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.