userd 0.2.0

A user daemon, managing services and regular running of jobs, in user space.
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

use futures::FutureExt;
use std::time::Duration;

use crate::prelude::*;

pub(crate) struct Every {
    duration: Duration,
}

impl Every {
    pub(crate) fn new(duration: Duration) -> Self {
        Self { duration }
    }
}

impl super::Trigger for Every {
    fn wait_for(&self) -> futures::future::BoxFuture<'static, Result<()>> {
        let duration = self.duration;
        async move {
            tokio::time::sleep(duration).await;
            Ok(())
        }
        .boxed()
    }
}