vyuh 0.2.11

Vyuh web framework for Axum and SQLx with handler-first APIs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

#[derive(Clone)]
pub struct CancellationNotifier(tokio_util::sync::CancellationToken);

impl CancellationNotifier {
    pub fn new() -> Self {
        Self(tokio_util::sync::CancellationToken::new())
    }

    pub fn child(&self) -> Self {
        Self(self.0.child_token())
    }

    pub(crate) fn notify_waiters(&self) {
        self.0.cancel();
    }

    pub async fn notified(&self) {
        self.0.cancelled().await;
    }

    #[cfg(test)]
    pub(crate) fn is_notified(&self) -> bool {
        self.0.is_cancelled()
    }
}