Module stream 

Stream adapters for synchronous, concurrent, and fallible transformations.

The module extends futures streams with ordered and completion-ordered concurrency, ready closures, aggregation, and result handling.

Modules

band 🔒

broadband 🔒

Broadband stream combinator extensions to futures::Stream

cloned 🔒

expect 🔒

ignore 🔒

iter_stream 🔒

ready 🔒

Synchronous combinator extensions to futures::Stream

tools 🔒

StreamTools for futures::Stream

try_broadband 🔒

Synchronous combinator extensions to futures::TryStream

try_parallel 🔒

Parallelism stream combinator extensions to futures::Stream

try_ready 🔒

Synchronous combinator extensions to futures::TryStream

try_tools 🔒

TryStreamTools for futures::TryStream

try_wideband 🔒

Synchronous combinator extensions to futures::TryStream

wideband 🔒

Wideband stream combinator extensions to futures::Stream

Constants

AMPLIFICATION_LIMIT

Practicable limits on the stream amplifier.

WIDTH_LIMIT

Practicable limits on the stream width.

Traits

BroadbandExt

Adds concurrent transformations with completion-ordered output.

Cloned

Clones items yielded by a stream of shared references.

IterStream

Converts synchronous iterables into immediately ready streams.

ReadyExt

Adds synchronous counterparts to selected [StreamExt] combinators.

Tools

Adds aggregation, sampling, and folding operations to streams.

TryBroadbandExt

Adds bounded concurrent transformations with completion-ordered outputs.

TryExpect

Converts fallible stream items into values by expecting success.

TryIgnore

Selects successful or failed items from a result stream.

TryParallelExt

Adds unordered parallel transformations for fallible streams.

TryReadyExt

Adds synchronous combinators to fallible streams.

TryTools

Adds general-purpose operations to fallible streams.

TryWidebandExt

Adds bounded concurrent transformations with ordered transform results.

WidebandExt

Adds bounded concurrent transformations that preserve stream order.

Functions

automatic_amplification

Used by stream operations where the amplification hasn’t been manually supplied by the caller. Instead we provide a computed value.

automatic_width

Returns the live default concurrency width for stream operations.

set_amplification

Sets the live concurrency amplification. The first return value is the previous width which was replaced. The second return value is the value which was set after any applied limits.

set_width

Sets the live concurrency factor. The first return value is the previous width which was replaced. The second return value is the value which was set after any applied limits.