bookkeeper-client 0.2.1

Async rust client for Apache BookKeeper
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

pub struct DropOwner {
    _receiver: tokio::sync::mpsc::Receiver<()>,
}

#[derive(Clone)]
pub struct DropWatcher {
    sender: tokio::sync::mpsc::Sender<()>,
}

impl DropWatcher {
    pub async fn dropped(&mut self) {
        self.sender.closed().await;
    }
}

pub fn drop_watcher() -> (DropOwner, DropWatcher) {
    let (sender, receiver) = tokio::sync::mpsc::channel(1);
    (DropOwner { _receiver: receiver }, DropWatcher { sender })
}