Skip to main content

process_batched_future_stream_result

veilid_tools::future_queue

Function process_batched_future_stream_result 

Source 
pub async fn process_batched_future_stream_result<S, C, E, R>(
    future_stream: S,
    batch_size: usize,
    stop_token: StopToken,
    result_callback: C,
) -> Result<(), E>
where
    S: Stream,
    C: Fn(R) -> Result<(), E>,
    <S as Stream>::Item: Future<Output = R>,