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,

将输入流转换为节流后的输出流