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}) → Stream<T>
Emits only the first item emitted by the source Stream while window is open. [...]
throttleTime(Duration duration, {bool trailing: false}) → Stream<T>
Emits only the first item emitted by the source Stream within a time span of duration. [...]