with_daemon 0.2.1

An async client-daemon abstraction framework
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
26
27
28
29

use tokio::sync::mpsc;

pub struct Waiter {
    receiver: mpsc::Receiver<()>,
    token: Token,
}

#[derive(Clone)]
pub struct Token(#[allow(dead_code)] mpsc::Sender<()>);

impl Waiter {
    pub fn new() -> Self {
        let (sender, receiver) = mpsc::channel::<()>(1);
        Self {
            receiver,
            token: Token(sender),
        }
    }

    pub fn token(&self) -> Token {
        self.token.clone()
    }

    pub async fn wait(mut self) {
        drop(self.token);
        let res = self.receiver.recv().await;
        assert!(res.is_none());
    }
}