vyuh 0.2.2

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

#[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;
    }
}