1 2 3 4 5 6 7 8 9 10 11
use tokio_util::sync::CancellationToken; pub struct CancellationGuard<'a> { pub(super) token: &'a CancellationToken, } impl<'a> CancellationGuard<'a> { pub fn check(&self) -> bool { self.token.is_cancelled() } }