ThrottleExtensions<T> extension

Extends the Stream class with the ability to throttle events in various ways

on
  • Stream<T>

Methods

throttle(Stream window(T event), {bool trailing = false, bool leading = true}) → Stream<T>
Emits a value from the source Stream, then ignores subsequent source values while the window Stream is open, then repeats this process. [...]
throttleTime(Duration duration, {bool trailing = false, bool leading = true}) → Stream<T>
Emits a value from the source Stream, then ignores subsequent source values for a duration, then repeats this process. [...]