Function batch_process

pub fn batch_process<T, U, F>(
    s: RS2Stream<T>,
    batch_size: usize,
    processor: F,
) -> RS2Stream<U>
where
    F: FnMut(Vec<T>) -> Vec<U> + Send + 'static,
    T: Send + 'static,
    U: Send + 'static,

Batch processing for better throughput