pub fn buffer_time<R, T, S>(ms: u64, s: S) -> impl Stream<Item = Vec<T>>where R: Runtime, T: Clone, S: Stream<Item = T> + Unpin,
Buffer values over time windows. Uses the Runtime trait for timer functionality.