List of all items
Structs
- Batching
- BroadcastBuilder
- BroadcastStream
- CatchError
- ErrorNotify
- ParParams
- PullBuilder
- ReorderEnumerated
- Shared
- StatefulBatching
- StatefulMap
- StatefulThen
- TakeUntilError
- Tee
- TryEnumerate
- TryReorderEnumerated
- TryStatefulMap
- TryStatefulThen
- WeakShared
- builder::ComposeFutureFactory
- builder::FutFacChain
- builder::ParAsyncBuilder
- builder::ParAsyncTailBlockBuilder
- builder::ParBlockingBuilder
- builder::ParBuilder
- rt::JoinHandle
- state_stream::Handle
- state_stream::StateStream
Enums
Traits
- IndexStreamExt
- ParStreamExt
- StreamExt
- TryIndexStreamExt
- TryParStreamExt
- TryStreamExt
- builder::FnFactory
- builder::FutureFactory
- prelude::IndexStreamExt
- prelude::ParStreamExt
- prelude::StreamExt
- prelude::TryIndexStreamExt
- prelude::TryParStreamExt
- prelude::TryStreamExt
- rt::Runtime
- rt::SleepHandle
- rt::SpawnHandle
Functions
- get_buf_size_scale
- iter_blocking
- par_unfold
- par_unfold_blocking
- rt::block_on
- rt::block_on_executor
- rt::set_global_runtime
- rt::sleep
- rt::spawn
- rt::spawn_blocking
- set_buf_size_scale
- sync_by_key
- try_par_unfold
- try_par_unfold_blocking
- try_sync_by_key
Typedefs
- ParMap
- ParThen
- TryParBatching
- TryParUnfold
- TryParUnfoldBlocking
- WithState
- builder::BoxFnFactory
- builder::BoxFutureFactory
- builder::OrderedStream
- builder::UnorderedStream