bufferTime method

Stream<List<T>> bufferTime (
  1. Duration duration
)

Creates a Stream where each item is a List containing the items from the source sequence, sampled on a time frame with duration.

Example

Stream.periodic(Duration(milliseconds: 100), (int i) => i)
  .bufferTime(Duration(milliseconds: 220))
  .listen(print); // prints [0, 1] [2, 3] [4, 5] ...

Implementation

Stream<List<T>> bufferTime(Duration duration) {
  if (duration == null) throw ArgumentError.notNull('duration');

  return buffer(Stream<void>.periodic(duration));
}