Function process_batched_future_queue

pub async fn process_batched_future_queue<I, C, F, R>(
    future_queue: I,
    batch_size: usize,
    stop_token: StopToken,
    result_callback: C,
)
where
    I: IntoIterator,
    C: Fn(R) -> F,
    F: Future<Output = ()>,
    <I as IntoIterator>::Item: Future<Output = R>,