Uses of Class
io.reactivex.rxjava3.observables.GroupedObservable
Packages that use GroupedObservable
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.-
Uses of GroupedObservable in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core that return types with arguments of type GroupedObservableModifier and TypeMethodDescriptionfinal <@NonNull K>
@NonNull Observable<GroupedObservable<K, T>> Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <@NonNull K>
@NonNull Observable<GroupedObservable<K, T>> Observable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, boolean delayError) Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <@NonNull K,
@NonNull V>
@NonNull Observable<GroupedObservable<K, V>> Observable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, boolean delayError) Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <@NonNull K,
@NonNull V>
@NonNull Observable<GroupedObservable<K, V>> Observable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, boolean delayError, int bufferSize) Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <@NonNull K,
@NonNull V>
@NonNull Observable<GroupedObservable<K, V>> Observable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, Function<? super @NonNull T, ? extends @NonNull V> valueSelector) Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s. -
Uses of GroupedObservable in io.reactivex.rxjava3.internal.operators.observable
Subclasses of GroupedObservable in io.reactivex.rxjava3.internal.operators.observableModifier and TypeClassDescription(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type GroupedObservableModifier and TypeFieldDescription(package private) final Observer
<? super GroupedObservable<K, V>> ObservableGroupBy.GroupByObserver.downstream
Method parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type GroupedObservableModifier and TypeMethodDescriptionvoid
ObservableGroupBy.subscribeActual
(Observer<? super GroupedObservable<K, V>> t) Constructor parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type GroupedObservable