ReactiveSubjectUtilitiesExtension<T> extension

on

• ReactiveSubject<T>

Methods

debug({String? tag, void onValue(T value)?, void onError(Object error)?}) → ReactiveSubject<T>

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

Adds debugging capabilities to the ReactiveSubject by logging events.

doOnData(void onData(T event)) → ReactiveSubject<T>

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

Performs a side-effect action for each data event emitted by the source ReactiveSubject.

doOnError(void onError(Object error, StackTrace stackTrace)) → ReactiveSubject<T>

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

Performs a side-effect action for each error event emitted by the source ReactiveSubject.

listen(void onData(T value), {Function? onDone, Function? onError, bool? cancelOnError}) → StreamSubscription<T>

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

Listens to the stream and calls the provided callbacks.

pairwise() → ReactiveSubject<List<T>>

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

Emits the previous and current values as a pair.

skipLast(int count) → ReactiveSubject<T>

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

Skips the last count items emitted by the source ReactiveSubject.

takeLast(int count) → ReactiveSubject<T>

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

Takes the last count items emitted by the source ReactiveSubject.

takeWhileInclusive(bool test(T event)) → ReactiveSubject<T>

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

Emits items from the source ReactiveSubject while the test function returns true. Unlike Stream.takeWhile, this includes the first item that fails the test.

timeInterval() → ReactiveSubject<TimeInterval<T>>

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

Emits the time interval between consecutive emissions.

timestamp() → ReactiveSubject<Timestamped<T>>

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

Emits each item with a timestamp indicating when it was emitted.