Struct CancellationToken 

pub struct CancellationToken { /* private fields */ }

Cancellation token for signaling shutdown

Lightweight clone-able token that can be passed to async tasks.

Examples

use adaptive_pipeline_bootstrap::shutdown::ShutdownCoordinator;
use std::time::Duration;

let coordinator = ShutdownCoordinator::new(Duration::from_secs(5));
let token = coordinator.token();

// Pass token to async task
tokio::spawn(async move {
    tokio::select! {
        _ = token.cancelled() => {
            println!("Task received shutdown signal");
        }
        _ = async { /* do work */ } => {
            println!("Task completed normally");
        }
    }
});

// Later, initiate shutdown
coordinator.initiate_shutdown();

Implementations

impl CancellationToken

pub fn cancel(&self)

Cancel this token

pub fn is_cancelled(&self) -> bool

Check if cancelled (non-blocking)

pub async fn cancelled(&self)

Wait for cancellation (async)

Trait Implementations

impl Clone for CancellationToken

fn clone(&self) -> CancellationToken

Returns a duplicate of the value.

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

Performs copy-assignment from source.