async-rx

异步响应式编程工具函数。

此 crate 故意做得非常小，因为它只提供在 futures-util 中找不到的实用工具。它旨在作为补充，而不是替换现有的知名 futures crate。

当前提供的功能

• StreamExt::dedup 用于去重连续相等的项目
• StreamExt::dedup_by_key 用于去重具有相等属性的连续项目
• StreamExt::batch_with 用于灵活批处理流的项目

lib.rs:

异步响应式编程工具函数。

此 crate 故意做得非常小，因为它只提供在 futures-util 中找不到的实用工具。它旨在作为补充，而不是替换现有的知名 futures crate。