Uses of Class
io.reactivex.rxjava3.flowables.GroupedFlowable

Packages that use GroupedFlowable

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.flowable

Uses of GroupedFlowable in io.reactivex.rxjava3.core

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

Modifier and Type	Method	Description
final <@NonNull K> @NonNull Flowable<GroupedFlowable<K,T>>	Flowable.groupBy(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector)	Groups the items emitted by the current Flowable according to a specified criterion, and emits these grouped items as GroupedFlowables.
final <@NonNull K> @NonNull Flowable<GroupedFlowable<K,T>>	Flowable.groupBy(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, boolean delayError)	Groups the items emitted by the current Flowable according to a specified criterion, and emits these grouped items as GroupedFlowables.
final <@NonNull K, @NonNull V> @NonNull Flowable<GroupedFlowable<K,V>>	Flowable.groupBy(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector)	Groups the items emitted by the current Flowable according to a specified criterion, and emits these grouped items as GroupedFlowables.
final <@NonNull K, @NonNull V> @NonNull Flowable<GroupedFlowable<K,V>>	Flowable.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 Flowable according to a specified criterion, and emits these grouped items as GroupedFlowables.
final <@NonNull K, @NonNull V> @NonNull Flowable<GroupedFlowable<K,V>>	Flowable.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 Flowable according to a specified criterion, and emits these grouped items as GroupedFlowables.
final <@NonNull K, @NonNull V> @NonNull Flowable<GroupedFlowable<K,V>>	Flowable.groupBy(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, boolean delayError, int bufferSize, @NonNull Function<? super Consumer<Object>, ? extends Map<@NonNull K, Object>> evictingMapFactory)	Groups the items emitted by the current Flowable according to a specified criterion, and emits these grouped items as GroupedFlowables.

Uses of GroupedFlowable in io.reactivex.rxjava3.internal.operators.flowable

Subclasses with type arguments of type GroupedFlowable in io.reactivex.rxjava3.internal.operators.flowable

Modifier and Type	Class	Description
final class	FlowableGroupBy<T,K,V>

Method parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type GroupedFlowable

Modifier and Type	Method	Description
protected void	FlowableGroupBy.subscribeActual(org.reactivestreams.Subscriber<? super GroupedFlowable<K,V>> s)

Constructor parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type GroupedFlowable

Modifier	Constructor	Description
	GroupBySubscriber(org.reactivestreams.Subscriber<? super GroupedFlowable<K,V>> actual, Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, int bufferSize, boolean delayError, Map<Object, io.reactivex.rxjava3.internal.operators.flowable.FlowableGroupBy.GroupedUnicast<K,V>> groups, Queue<io.reactivex.rxjava3.internal.operators.flowable.FlowableGroupBy.GroupedUnicast<K,V>> evictedGroups)