StreamDebounceExtensions<T> extension

Chainable debounce variants on any Stream, so reactive pipelines read as stream.debounce(d).map(...) instead of wrapping with the free function.

on

Methods

debounce(Duration duration) → Stream<T>: Available on Stream<T>, provided by the StreamDebounceExtensions extension
Debounces this stream: see debounceStream. Only the latest value of each duration-bounded burst survives.
debounceAfterFirst(Duration duration) → Stream<T>: Available on Stream<T>, provided by the StreamDebounceExtensions extension
Emits the FIRST value immediately, then debounces the rest by duration.
debounceDistinct(Duration duration, {bool equals(T previous, T next)?}) → Stream<T>: Available on Stream<T>, provided by the StreamDebounceExtensions extension
Debounces this stream AND suppresses consecutive equal values.