polymer-core 0.1.0

Core traits for embedded async IO
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

use core::{future::Future, time::Duration};

use futures_core::stream::Stream;

pub trait Timer: Sized {
    type Error;

    type Timeout: Future<Output = Result<Self, Self::Error>>;

    type Interval: Stream<Item = Result<(), Self::Error>>;

    fn timeout(self, duration: Duration) -> Self::Timeout;

    fn interval(self, duration: Duration) -> Self::Interval;
}

/* TODO: Use this
pub trait Timer {
    type Error;

    fn timeout(
        self: Pin<Self>,
        duration: Time,
    ) -> impl StableFuture<Item = (), Error = Self::Error> + '_;

    fn interval(
        self: Pin<Self>,
        duration: Time,
    ) -> impl StableStream<Item = (), Error = Self::Error> + '_;
}
*/