Struct McpRequestCancellationBridge 

struct McpRequestCancellationBridge {
    stop: Arc<AtomicBool>,
    monitor: Option<JoinHandle<()>>,
    context: Option<RequestContext<RoleServer>>,
}

Bridge one RMCP request cancellation token into synchronous index work.

Fields

stop: Arc<AtomicBool>

Signal used to stop the request-local cancellation monitor.

monitor: Option<JoinHandle<()>>

Join handle for the bounded request-local monitor thread.

context: Option<RequestContext<RoleServer>>

Owned RMCP request context retained for the final cancellation check.

Implementations

impl McpRequestCancellationBridge

fn start( context: RequestContext<RoleServer>, control: &IndexWorkControl, ) -> Result<Self, CliError>

Start a request-local monitor from one owned RMCP context.

fn start_with_probe_and_context<P>( probe: P, control: &IndexWorkControl, context: Option<RequestContext<RoleServer>>, ) -> Result<Self, CliError>

where P: Fn() -> bool + Send + 'static,

Start a cancellation monitor and retain its owning request context.

fn is_cancelled(&self) -> bool

Return whether RMCP canceled the owning request.

Trait Implementations

impl Drop for McpRequestCancellationBridge

fn drop(&mut self)

Executes the destructor for this type.