diff options
| -rw-r--r-- | ipfs-api/examples/pubsub.rs | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/ipfs-api/examples/pubsub.rs b/ipfs-api/examples/pubsub.rs index 6fef446..baa1b1b 100644 --- a/ipfs-api/examples/pubsub.rs +++ b/ipfs-api/examples/pubsub.rs @@ -13,6 +13,7 @@ use futures::{future, FutureExt, StreamExt, TryStreamExt}; use ipfs_api::IpfsClient; use std::time::Duration; use tokio::time; +use tokio_stream::wrappers::IntervalStream; static TOPIC: &'static str = "test"; @@ -35,7 +36,8 @@ async fn main() { // This block will execute a repeating function that sends // a message to the "test" topic. // - let mut publish = time::interval(Duration::from_secs(1)) + let interval = time::interval(Duration::from_secs(1)); + let mut publish = IntervalStream::new(interval) .then(|_| future::ok(())) // Coerce the stream into a TryStream .try_for_each(|_| { eprintln!(); |