Crate loop

Processing iterators in parallel.

Examples

Synchronously:

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

Asynchronously:

 #[tokio::main]
 async fn main() {
     use futures::stream::StreamExt;

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

Functions

• parallelize
  Process an iterator in parallel.