cancel_safe_futures/stream/mod.rs
1//! Alternative adapters for asynchronous streams.
2//!
3//! This module contains adapters that are similar to the `try_` adapters in the [`futures::stream`]
4//! module, but don't cancel other futures if one of them errors out.
5
6mod try_stream;
7pub use try_stream::TryStreamExt;
8
9mod collect_then_try;
10pub use collect_then_try::CollectThenTry;
11
12#[cfg(not(futures_no_atomic_cas))]
13#[cfg(feature = "alloc")]
14mod for_each_concurrent_then_try;
15#[cfg(not(futures_no_atomic_cas))]
16#[cfg(feature = "alloc")]
17pub use for_each_concurrent_then_try::ForEachConcurrentThenTry;