rust-lang / futures-rs

Zero-cost asynchronous programming in Rust
https://rust-lang.github.io/futures-rs/
Apache License 2.0
5.38k stars 622 forks source link

Add `TryStreamExt::try_{any,all}` to mirror `StreamExt::{any,all}` #2771

Closed nightkr closed 11 months ago

nightkr commented 1 year ago

There's no nice way to build this with the current combinators, without either buffering the whole stream (try_collect()) and relying on Iterator::{any,all}, or ignoring errors and using StreamExt::{any,all}