Function run_ordered_parallel

core/src/ordered_parallel.rs:32–44

(
    items: Vec<I>,
    run: F,
)

#[cfg(test)]
pub(crate) async fn run_ordered_parallel<I, F, Fut, T>(
    items: Vec<I>,
    run: F,
) -> Vec<OrderedParallelResult<T>>
where
    I: Send + 'static,
    F: Fn(usize, I) -> Fut + Clone + Send + 'static,
    Fut: Future<Output = T> + Send + 'static,
    T: Send + 'static,
{
    let item_count = items.len();
    run_ordered_parallel_with_limit(items, item_count.max(1), run).await
}

pub(crate) async fn run_ordered_parallel_with_limit<I, F, Fut, T>(
    items: Vec<I>,