diff options
Diffstat (limited to 'futures')
| -rw-r--r-- | futures/src/backend/native/tokio.rs | 11 | ||||
| -rw-r--r-- | futures/src/subscription.rs | 3 |
2 files changed, 7 insertions, 7 deletions
diff --git a/futures/src/backend/native/tokio.rs b/futures/src/backend/native/tokio.rs index e0be83a6..c38ef566 100644 --- a/futures/src/backend/native/tokio.rs +++ b/futures/src/backend/native/tokio.rs @@ -23,11 +23,10 @@ impl crate::Executor for Executor { pub mod time { //! Listen and react to time. use crate::core::time::{Duration, Instant}; - use crate::stream; use crate::subscription::Subscription; use crate::MaybeSend; - use futures::SinkExt; + use futures::stream; use std::future::Future; /// Returns a [`Subscription`] that produces messages at a set interval. @@ -66,12 +65,12 @@ pub mod time { let f = *f; let interval = *interval; - stream::channel(1, move |mut output| async move { - loop { - let _ = output.send(f().await).await; - + stream::unfold(0, move |i| async move { + if i > 0 { tokio::time::sleep(interval).await; } + + Some((f().await, i + 1)) }) }) } diff --git a/futures/src/subscription.rs b/futures/src/subscription.rs index 82cba9a1..3577d19f 100644 --- a/futures/src/subscription.rs +++ b/futures/src/subscription.rs @@ -210,7 +210,8 @@ impl<T> Subscription<T> { /// Returns a [`Subscription`] that will create and asynchronously run the /// given [`Stream`]. /// - /// The `id` will be used to uniquely identify the [`Subscription`]. + /// Both the `data` and the function pointer will be used to uniquely identify + /// the [`Subscription`]. pub fn run_with<D, S>(data: D, builder: fn(&D) -> S) -> Self where D: Hash + 'static, |