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)

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

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

Transform value before calling callback. Named listenMapped to distinguish from RxComputedExtensions.map which returns a computed value rather than registering a callback.

listenWhere(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. Named listenWhere to distinguish from RxComputedExtensions.where which returns a computed value rather than registering a 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

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

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

Skip first n value changes (callback-style listener) NOTE: Named skipFirst to avoid ambiguity with RxTransformations.skip which returns a computed value instead of registering a callback.

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

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

Take only first n value changes (callback-style listener) NOTE: Named takeFirst to avoid ambiguity with RxTransformations.take which returns a computed value instead of registering a callback.

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