memberlist-core 0.1.1

A highly customable, adaptable, async runtime agnostic Gossip protocol which helps manage cluster membership and member failure detection.
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
30
31
32
33
34
35
36
37
38
39
40
41
42
43

use agnostic::Runtime;
use futures::{channel::oneshot, future::FutureExt, select, Future};
use std::time::Duration;

pub(crate) struct Timer {
  #[allow(dead_code)]
  fut: oneshot::Receiver<()>,
  cancel: oneshot::Sender<()>,
}

impl Timer {
  pub(crate) fn after<F, R>(dur: Duration, future: F) -> Self
  where
    R: Runtime,
    <R::Sleep as Future>::Output: Send,
    F: std::future::Future<Output = ()> + Send + 'static,
  {
    let (cancel_tx, cancel_rx) = oneshot::channel();
    let (tx, rx) = oneshot::channel();
    R::spawn_detach(
      async move {
        let delay = R::sleep(dur);
        select! {
          _ = delay.fuse() => {
            future.await;
            let _ = tx.send(());
          },
          _ = cancel_rx.fuse() => {},
        }
      }
      .boxed(),
    );

    Timer {
      fut: rx,
      cancel: cancel_tx,
    }
  }

  pub(crate) async fn stop(self) {
    let _ = self.cancel.send(());
  }
}