summaryrefslogtreecommitdiffstats
path: root/futures/src/time.rs
diff options
context:
space:
mode:
Diffstat (limited to 'futures/src/time.rs')
-rw-r--r--futures/src/time.rs10
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()
}
}