streamedInterval<T, E> method

StreamedIntervalTimer streamedInterval<T, E>(
  1. Stream<T> valueStream,
  2. Duration duration,
  3. dynamic fn(
    1. T?
    ), {
  4. Symbol? uniqueId,
})

Implementation

StreamedIntervalTimer streamedInterval<T, E>(
    Stream<T> valueStream, Duration duration, Function(T?) fn,
    {Symbol? uniqueId}) {
  final tm = StreamedIntervalTimer(fn, duration, execNow: true);

  each<T>(valueStream, (ev) {
    tm.add(ev);
  });

  _timer(tm, uniqueId: uniqueId);

  return tm;
}