Struct MiddlewareStack 

pub struct MiddlewareStack<H: McpHandler> { /* private fields */ }

A handler wrapped with a middleware stack.

This implements McpHandler and runs requests through the middleware chain.

Implementations

impl<H: McpHandler> MiddlewareStack<H>

pub fn new(handler: H) -> Self

Create a new middleware stack wrapping the given handler.

pub fn with_middleware<M: McpMiddleware>(self, middleware: M) -> Self

Add a middleware to the stack.

Middlewares are called in the order they are added.

pub fn middleware_count(&self) -> usize

Get the number of middlewares in the stack.

Trait Implementations

impl<H: McpHandler> Clone for MiddlewareStack<H>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<H: McpHandler> Debug for MiddlewareStack<H>

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

Formats the value using the given formatter.

impl<H: McpHandler> McpHandler for MiddlewareStack<H>

fn server_info(&self) -> ServerInfo

Returns server information (name, version, description, etc.)

fn list_tools(&self) -> Vec<Tool>

Returns all available tools.

fn list_resources(&self) -> Vec<Resource>

Returns all available resources.

fn list_prompts(&self) -> Vec<Prompt>

Returns all available prompts.

fn call_tool<'a>( &'a self, name: &'a str, args: Value, ctx: &'a RequestContext, ) -> impl Future<Output = McpResult<ToolResult>> + MaybeSend + 'a

Calls a tool by name with the given arguments.

fn read_resource<'a>( &'a self, uri: &'a str, ctx: &'a RequestContext, ) -> impl Future<Output = McpResult<ResourceResult>> + MaybeSend + 'a

Reads a resource by URI.

fn get_prompt<'a>( &'a self, name: &'a str, args: Option<Value>, ctx: &'a RequestContext, ) -> impl Future<Output = McpResult<PromptResult>> + MaybeSend + 'a

Gets a prompt by name with optional arguments.

fn on_initialize(&self) -> impl Future<Output = McpResult<()>> + MaybeSend

Called when the server is initialized.

fn on_shutdown(&self) -> impl Future<Output = McpResult<()>> + MaybeSend

Called when the server is shutting down.

fn list_tasks<'a>( &'a self, _cursor: Option<&'a str>, _limit: Option<usize>, _ctx: &'a RequestContext, ) -> impl Future<Output = Result<ListTasksResult, McpError>> + MaybeSend + 'a

Lists all active and recent tasks.

fn get_task<'a>( &'a self, _task_id: &'a str, _ctx: &'a RequestContext, ) -> impl Future<Output = Result<Task, McpError>> + MaybeSend + 'a

Gets the current state of a specific task.

fn cancel_task<'a>( &'a self, _task_id: &'a str, _ctx: &'a RequestContext, ) -> impl Future<Output = Result<Task, McpError>> + MaybeSend + 'a

Cancels a running task.

fn get_task_result<'a>( &'a self, _task_id: &'a str, _ctx: &'a RequestContext, ) -> impl Future<Output = Result<Value, McpError>> + MaybeSend + 'a

Gets the result of a completed task.