Uses of Class
io.reactivex.rxjava3.flowables.GroupedFlowable
Packages that use GroupedFlowable
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.-
Uses of GroupedFlowable in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core that return types with arguments of type GroupedFlowableModifier and TypeMethodDescriptionfinal <@NonNull K>
@NonNull Flowable<GroupedFlowable<K, T>> Groups the items emitted by the currentFlowable
according to a specified criterion, and emits these grouped items asGroupedFlowable
s.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 currentFlowable
according to a specified criterion, and emits these grouped items asGroupedFlowable
s.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 currentFlowable
according to a specified criterion, and emits these grouped items asGroupedFlowable
s.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 currentFlowable
according to a specified criterion, and emits these grouped items asGroupedFlowable
s.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 currentFlowable
according to a specified criterion, and emits these grouped items asGroupedFlowable
s.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 currentFlowable
according to a specified criterion, and emits these grouped items asGroupedFlowable
s. -
Uses of GroupedFlowable in io.reactivex.rxjava3.internal.operators.flowable
Subclasses of GroupedFlowable in io.reactivex.rxjava3.internal.operators.flowableModifier and TypeClassDescription(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type GroupedFlowableModifier and TypeFieldDescription(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 GroupedFlowableModifier and TypeMethodDescriptionprotected 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 GroupedFlowableModifierConstructorDescriptionGroupBySubscriber
(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)