Struct McpRequestCancellationBridge 

struct McpRequestCancellationBridge {
    stop: Arc<AtomicBool>,
    monitor: Option<JoinHandle<()>>,
    probe: Arc<dyn Fn() -> bool + Send + Sync>,
}

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.

probe: Arc<dyn Fn() -> bool + Send + Sync>

Direct request probe retained for synchronous cancellation fences.

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<P>( probe: P, control: &IndexWorkControl, ) -> Result<Self, CliError>

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

Start a cancellation monitor from a deterministic probe for tests.

fn synchronize(&self, control: &IndexWorkControl)

Copy the request token into synchronous index-work cancellation.

Trait Implementations

impl Drop for McpRequestCancellationBridge

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.