parallel_map

chie_core::batch

Function parallel_map 

Source 
pub async fn parallel_map<T, R, E, F, Fut>(
    items: Vec<T>,
    max_concurrent: usize,
    f: F,
) -> BatchResult<R, E>
where
    T: Send + 'static,
    R: Send + 'static,
    E: Send + 'static,
    F: Fn(T) -> Fut + Send + Sync + 'static,
    Fut: Future<Output = Result<R, E>> + Send,
Expand description

Process items in parallel with a simple function.