tuwunel_core/utils/stream/
mod.rs

1//! Stream adapters for synchronous, concurrent, and fallible transformations.
2//!
3//! The module extends futures streams with ordered and completion-ordered
4//! concurrency, ready closures, aggregation, and result handling.
5
6mod band;
7mod broadband;
8mod cloned;
9mod expect;
10mod ignore;
11mod iter_stream;
12mod ready;
13mod tools;
14mod try_broadband;
15mod try_parallel;
16mod try_ready;
17mod try_tools;
18mod try_wideband;
19mod wideband;
20
21pub use self::{
22	band::{
23		AMPLIFICATION_LIMIT, WIDTH_LIMIT, automatic_amplification, automatic_width,
24		set_amplification, set_width,
25	},
26	broadband::BroadbandExt,
27	cloned::Cloned,
28	expect::TryExpect,
29	ignore::TryIgnore,
30	iter_stream::IterStream,
31	ready::ReadyExt,
32	tools::Tools,
33	try_broadband::TryBroadbandExt,
34	try_parallel::TryParallelExt,
35	try_ready::TryReadyExt,
36	try_tools::TryTools,
37	try_wideband::TryWidebandExt,
38	wideband::WidebandExt,
39};
tuwunel_core/utils/stream/mod.rs

tuwunel_core/utils/stream/
mod.rs
