Synchronous combinators to augment futures::StreamExt. Most Stream
combinators take asynchronous arguments, but often only simple predicates
are required to steer a Stream like an Iterator. This suite provides a
convenience to reduce boilerplate by de-cluttering non-async predicates.
Parallelism extensions to augment futures::StreamExt. These combinators are
for computation-oriented workloads, unlike -band combinators for I/O
workloads; these default to the available compute parallelism for the
system. Threads are currently drawn from the tokio-spawn pool. Results are
unordered.
Used by stream operations where the concurrency factor hasn’t been manually
supplied by the caller (most uses). Instead we provide a default value which
is adjusted at startup for the specific system and also dynamically.
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.
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.