Function tokio::time::throttle

pub fn throttle<T>(duration: Duration, stream: T) -> Throttle<T> where
    T: Stream, 

This is supported on feature="time" only.

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);
}