Throttle<T> extension

Throttle related stream extensions

on

• Stream<T>

Methods

throttleByCountAndTime({int? throttleCount, Duration? duration, bool throttleIf(T value)?}) → Stream<T>

Emits the first event from the source, and then emits one event every time the throttleCount is reached or the duration since the last event has been reached