Change stream

仅当值不同时才发出流的工具。

重要

• 流项通过克隆存储在结构体中，因此流项必须实现 Clone
• 项目之间的比较是通过相等检查完成的，因此项必须实现与自身的 PartialEq

示例用法

• 将以下内容添加到您的Cargo.toml文件中

[dependencies]
change_stream = "0.1.0"

• 导入 StreamChanged 特性，并在现有流上调用 .changed()

use change_stream::StreamChanged;
use futures::{stream::iter, StreamExt};

#[tokio::main]
async fn main() {
    let a = iter([1, 1, 2]);

    a.changed().for_each(|a| async move {
        dbg!(a); //will only emit 1 and 2
    }).await;
}