Function throttle_stream 

pub fn throttle_stream<S, T>(
    input_stream: S,
    duration: Duration,
) -> impl Stream<Item = Vec<T>>
where
    S: Stream<Item = T> + Send + 'static,
    T: Send + 'static,