Skip to main content

buffer_time

Function buffer_time 

Source
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,
Expand description

Buffer values over time windows. Uses the Runtime trait for timer functionality.