RxTimingExtensions<T> extension

Timing extensions for reactive values

on

• Rx<T>

Methods

buffer(Duration duration, void callback(List<T> values)) → void

Available on Rx<T>, provided by the RxTimingExtensions extension

Buffer value changes for specified duration

debounce(Duration duration, void callback(T value)) → void

Available on Rx<T>, provided by the RxTimingExtensions extension

Debounce value changes - callback is called after duration of inactivity

delay(Duration duration, void callback(T value)) → void

Available on Rx<T>, provided by the RxTimingExtensions extension

Delay value changes by specified duration

distinct(void callback(T value), [bool equals(T previous, T current)?]) → void

Available on Rx<T>, provided by the RxTimingExtensions extension

Only call callback when value actually changes (distinct)

map<R>(R transformer(T value), void callback(R value)) → void

Available on Rx<T>, provided by the RxTimingExtensions extension

Transform value before calling callback

sample(Duration interval, void callback(T value)) → StreamSubscription<T>

Available on Rx<T>, provided by the RxTimingExtensions extension

Sample value changes at regular intervals

skip(int count, void callback(T value)) → void

Available on Rx<T>, provided by the RxTimingExtensions extension

Skip first n value changes

take(int count, void callback(T value)) → void

Available on Rx<T>, provided by the RxTimingExtensions extension

Take only first n value changes

throttle(Duration duration, void callback(T value)) → void

Available on Rx<T>, provided by the RxTimingExtensions extension

Throttle value changes - callback is called at most once per duration

where(bool condition(T value), void callback(T value)) → void

Available on Rx<T>, provided by the RxTimingExtensions extension

Only call callback when value meets condition