dht-rpc 0.0.2

rust implementation of the DHT powering the hyperswarm stack
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

use std::{pin::Pin, time::Duration};

use futures::task::{Context, Poll};
use wasm_timer::{Delay, Instant};

#[derive(Debug)]
pub struct PeriodicJob {
    pub interval: Duration,
    pub inner: Delay,
}

impl PeriodicJob {
    pub fn new(interval: Duration) -> Self {
        Self {
            interval,
            inner: Delay::new(interval),
        }
    }

    pub fn poll_now(&mut self, cx: &mut Context<'_>) -> Poll<()> {
        if let Poll::Ready(Ok(_)) = Delay::poll(Pin::new(&mut self.inner), cx) {
            let deadline = Instant::now() + self.interval;
            self.inner = Delay::new_at(deadline);
            Poll::Ready(())
        } else {
            Poll::Pending
        }
    }

    pub fn poll(&mut self, cx: &mut Context<'_>, now: Instant) -> Poll<()> {
        if let Poll::Ready(Ok(_)) = Delay::poll(Pin::new(&mut self.inner), cx) {
            let deadline = now + self.interval;
            self.inner = Delay::new_at(deadline);
            Poll::Ready(())
        } else {
            Poll::Pending
        }
    }
}