rust-stream-ext-concurrent

对于任何futures::stream::Stream对象进行并发行为扩展。

详细信息

使用原生Rust futures基础设施futures::stream::FuturesUnordered在内部缓存并启用Stream对象的并发处理。

支持的扩展

• then_concurrent方法扩展了每个Stream，以添加使用FuturesUnordered的并发执行能力所需的功能