It seems Stream is not impl for Interval in tokio 1.0 ?

[valbendan]

I already have add tokio_stream to my dep

[Darksonn]

The tokio-stream crate cannot add an impl of Stream to tokio::time::Interval because neither the trait nor the type is defined in tokio-stream. Instead you can use the async-stream crate to turn it into a stream.

let stream = async_stream::stream! {
    loop {
        yield interval.tick().await;
    }
};

You can also implement Stream on your wrapper type like this:

use tokio::time::{Interval, Instant};
use std::pin::Pin;
use std::task::{Context, Poll};
use tokio_stream::Stream;

struct MyInterval {
    int: Interval,
}

impl Stream for MyInterval {
    type Item = Instant;

    fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Instant>> {
        self.int.poll_tick(cx).map(|inner| Some(inner))
    }
}

The tokio-stream crate should soon receive an update that makes this easier.