ThrottleExtensions<T> extension
Extends the Stream class with the ability to throttle events in various ways
- on
-
- Stream<
T>
- Stream<
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 windowStream
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. [...]