Skip to main content

process_batched_future_queue_result

veilid_tools::future_queue

Function process_batched_future_queue_result 

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