Function tokio::time::throttle [−][src]
pub fn throttle<T>(duration: Duration, stream: T) -> Throttle<T> where
T: Stream,
Slows down a stream by enforcing a delay between items. They will be produced not more often than the specified interval.
Example
Create a throttled stream.
use std::time::Duration; use tokio::stream::StreamExt; use tokio::time::throttle; let mut item_stream = throttle(Duration::from_secs(2), futures::stream::repeat("one")); loop { // The string will be produced at most every 2 seconds println!("{:?}", item_stream.next().await); }