Uses of Class
io.reactivex.rxjava3.observables.GroupedObservable

Packages that use GroupedObservable

Package	Description
io.reactivex.rxjava3.core	Base reactive classes: Flowable, Observable, Single, Maybe and Completable; base reactive consumers; other common base interfaces.
io.reactivex.rxjava3.internal.operators.observable

Uses of GroupedObservable in io.reactivex.rxjava3.core

Methods in io.reactivex.rxjava3.core that return types with arguments of type GroupedObservable

Modifier and Type	Method	Description
final <@NonNull K> @NonNull Observable<GroupedObservable<K,T>>	Observable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector)	Groups the items emitted by the current Observable according to a specified criterion, and emits these grouped items as GroupedObservables.
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 current Observable according to a specified criterion, and emits these grouped items as GroupedObservables.
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 current Observable according to a specified criterion, and emits these grouped items as GroupedObservables.
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 current Observable according to a specified criterion, and emits these grouped items as GroupedObservables.
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 current Observable according to a specified criterion, and emits these grouped items as GroupedObservables.

Uses of GroupedObservable in io.reactivex.rxjava3.internal.operators.observable

Subclasses of GroupedObservable in io.reactivex.rxjava3.internal.operators.observable

Modifier and Type	Class	Description
(package private) static final class	ObservableGroupBy.GroupedUnicast<K,T>

Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type GroupedObservable

Modifier and Type	Field	Description
(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 GroupedObservable

Modifier and Type	Method	Description
void	ObservableGroupBy.subscribeActual(Observer<? super GroupedObservable<K,V>> t)

Constructor parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type GroupedObservable

Modifier	Constructor	Description
	GroupByObserver(Observer<? super GroupedObservable<K,V>> actual, Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector, int bufferSize, boolean delayError)