1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

//! Alternative adapters for asynchronous streams.
//!
//! This module contains adapters that are similar to the `try_` adapters in the [`futures::stream`]
//! module, but don't cancel other futures if one of them errors out.

mod try_stream;
pub use try_stream::TryStreamExt;

mod collect_then_try;
pub use collect_then_try::CollectThenTry;

#[cfg(not(futures_no_atomic_cas))]
#[cfg(feature = "alloc")]
mod for_each_concurrent_then_try;
#[cfg(not(futures_no_atomic_cas))]
#[cfg(feature = "alloc")]
pub use for_each_concurrent_then_try::ForEachConcurrentThenTry;