Skip to main content

process_batched_future_stream_void

veilid_tools::future_queue

Function process_batched_future_stream_void 

Source 
pub async fn process_batched_future_stream_void<S>(
    future_stream: S,
    batch_size: usize,
    stop_token: StopToken,
)
where
    S: Stream,
    <S as Stream>::Item: Future<Output = ()>,