ReactiveSubjectStateManagementExtension<T> extension

on

• ReactiveSubject<T>

Methods

distinct([bool equals(T previous, T next)?]) → ReactiveSubject<T>

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

Emits all items emitted by the source ReactiveSubject that are distinct from their immediate predecessors.

distinctBy<K>(K keySelector(T value)) → ReactiveSubject<T>

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

Emits items that are distinct based on a key selector function. This is more efficient than distinct() when you only need to compare specific properties.

groupBy<K>(K keySelector(T value)) → ReactiveSubject<Map<K, List<T>>>

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

Groups stream events into separate lists based on a key selector function.

share() → ReactiveSubject<T>

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

Shares a single subscription to the source ReactiveSubject among multiple subscribers.

shareReplay({int maxSize = 1}) → ReactiveSubject<T>

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

Shares a single subscription and replays the specified number of latest values to new subscribers.