diff options
Diffstat (limited to '')
| -rw-r--r-- | futures/src/time.rs | 10 | 
1 files changed, 1 insertions, 9 deletions
| diff --git a/futures/src/time.rs b/futures/src/time.rs index c11942d2..86b4a4e7 100644 --- a/futures/src/time.rs +++ b/futures/src/time.rs @@ -35,16 +35,8 @@ where          _input: futures::stream::BoxStream<'static, E>,      ) -> futures::stream::BoxStream<'static, Self::Output> {          use futures::stream::StreamExt; -        use std::time::Instant; -        let duration = self.0; - -        futures::stream::unfold(Instant::now(), move |last_tick| async move { -            let last_tick = smol::Timer::at(last_tick + duration).await; - -            Some((last_tick, last_tick)) -        }) -        .boxed() +        smol::Timer::interval(self.0).boxed()      }  } | 
