windowTime method

Observable<Stream<T>> windowTime(
  1. Duration duration
)

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

Example

/ new Observable.periodic(const Duration(milliseconds: 100), (int i) => i) .windowTime(const Duration(milliseconds: 220)) .doOnData((_) => print('next window')) .flatMap((s) => s) .listen(print); // prints next window 0, 1, next window 2, 3, ...

Implementation

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

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