Module stream 

Structs

ConcurrencyConfig

Runtime configuration for adaptive concurrency control.

ConcurrencyStats

Snapshot of concurrency stats passed to the report callback.

Enums

Break

Wrapper type for errors to allow the body of a try_for_each_spawned call to signal that it either wants to return early (Break) out of the loop, or propagate an error (Err(E)).

Traits

TrySpawnStreamExt

Extension trait introducing try_for_each_spawned to all streams.