Struct CancellationManager 

pub struct CancellationManager { /* private fields */ }

Request cancellation manager

Implementations

impl CancellationManager

pub fn new() -> CancellationManager

Create a new cancellation manager

pub async fn register_request( &self, id: Value, method: String, ) -> Result<(), MCPError>

Register a new request for cancellation tracking

pub async fn cancel_request( &self, id: &Value, reason: Option<String>, ) -> Result<bool, MCPError>

Cancel a request

pub async fn is_cancelled(&self, id: &Value) -> bool

Check if a request has been cancelled

pub async fn complete_request(&self, id: &Value) -> Result<(), MCPError>

Remove a completed request

pub async fn active_requests(&self) -> Vec<CancellableRequest>

Get all active requests

pub async fn cleanup_old_requests( &self, max_age: Duration, ) -> Result<usize, MCPError>

Clean up old requests (older than max_age)

pub async fn handle_cancellation( &self, notification: CancelledNotification, ) -> Result<bool, MCPError>

Handle a cancellation notification

Trait Implementations

impl Debug for CancellationManager

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

Formats the value using the given formatter.

impl Default for CancellationManager

fn default() -> CancellationManager

Returns the “default value” for a type.