Skip to main content

execute_with_concurrency_limit

Function execute_with_concurrency_limit 

Source
pub async fn execute_with_concurrency_limit<F, Fut, T>(
    operations: Vec<F>,
    limit: usize,
) -> Vec<T>
where F: FnOnce() -> Fut, Fut: Future<Output = T>, T: Send + 'static,
Expand description

Execute multiple futures concurrently with a limit