Num Stream

此包提供了一个 Stream，该Stream在指定的时间间隔产生数值，并以指定的速率递增。

API文档

crates.io

此包源于对简单可配置的Stream的需求，该Stream会产生不断变化的、但可预测的值。

可以使用 num_stream 方法获取 NumStream 结构体实例，该结构体实现了Futures 0.3 Stream。

示例

use futures::stream::StreamExt;
use num_stream::num_stream;
use std::time::Duration;
use tokio;

#[tokio::main]
async fn main() {
    let mut nums = num_stream(0, 3, Duration::from_millis(500));
    loop {
        println!("Got: {:?}", nums.next().await);
    }
}

许可证