ReactiveSubjectTimeControlExtension<T> extension

on

• ReactiveSubject<T>

Methods

buffer(Stream closing) → ReactiveSubject<List<T>>

Available on ReactiveSubject<T>, provided by the ReactiveSubjectTimeControlExtension extension

Buffers values from the source ReactiveSubject until the closing stream emits.

debounceTime(Duration duration) → ReactiveSubject<T>

Available on ReactiveSubject<T>, provided by the ReactiveSubjectTimeControlExtension extension

Emits items from the source ReactiveSubject only after a specified duration has passed without the ReactiveSubject emitting any other items.

throttleTime(Duration duration) → ReactiveSubject<T>

Available on ReactiveSubject<T>, provided by the ReactiveSubjectTimeControlExtension extension

Emits the first item emitted by the source ReactiveSubject in each time window of a specified duration.