streamedInterval<T, E> method
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;
}