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 of GroupedFlowable in io.reactivex.rxjava3.internal.operators.flowable

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

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

Modifier and Type	Field	Description
(package private) final org.reactivestreams.Subscriber<? super GroupedFlowable<K,V>>	FlowableGroupBy.GroupBySubscriber.downstream

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,FlowableGroupBy.GroupedUnicast<K,V>> groups, Queue<FlowableGroupBy.GroupedUnicast<K,V>> evictedGroups)