Utilities for running computations in parallel on top of Tokio
This library adds utility methods and stream transformers to Streams and
TryStreams, to make it easier to run many futures in parallel while
adhering to structured parallelism best-practices. Each stream transformer
propagates panics and cancellation correctly, and ensures that tasks aren't
leaked, that the program waits for Drop impls to run on other tasks before
continuing execution, etc.
To use this library, simply call parallel_* methods on Streams or
TryStreams by importing the extension traits, StreamParExt or
TryStreamParExt.
Consult the latest API docs for more information.