Loop

The package allows for processing iterators in parallel.

Example

let double = |value| 2 * value;
let _ = r#loop::parallelize(0..10, double, None).collect::<Vec<_>>();

use futures::stream::StreamExt;

let double = |value| async move { 2 * value };
let _ = r#loop::parallelize(0..10, double, None).collect::<Vec<_>>().await;

Contribution

Your contribution is highly appreciated. Do not hesitate to open an issue or a pull request. Note that any contribution submitted for inclusion in the project will be licensed according to the terms given in LICENSE.md.