Top Inners Fields Constructors Methods
io.reactivex.internal.operators.flowable

public final Class FlowableGroupBy<T, K, V>

extends AbstractFlowableWithUpstream<T, GroupedFlowable<K, V>>
Class Inheritance
Imports
java.util.Map, .Queue, java.util.concurrent.ConcurrentHashMap, .ConcurrentLinkedQueue, java.util.concurrent.atomic.*, org.reactivestreams.*, io.reactivex.*, io.reactivex.annotations.Nullable, io.reactivex.exceptions.Exceptions, io.reactivex.flowables.GroupedFlowable, io.reactivex.functions.Consumer, .Function, io.reactivex.internal.functions.ObjectHelper, io.reactivex.internal.queue.SpscLinkedArrayQueue, io.reactivex.internal.subscriptions.*, io.reactivex.internal.util.BackpressureHelper, .EmptyComponent, io.reactivex.plugins.RxJavaPlugins

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
FlowableGroupBy.EvictionAction<K, V>

public static class
FlowableGroupBy.GroupBySubscriber<T, K, V>

pack-priv static class
FlowableGroupBy.GroupedUnicast<K, T>

pack-priv static class
FlowableGroupBy.State<T, K>

Field Summary

Modifier and TypeField and Description
pack-priv final int
bufferSize

pack-priv final boolean
delayError

pack-priv final Function<? super T, ? extends K>
keySelector

pack-priv final Function<? super Consumer<Object>, ? extends Map<K, Object>>
mapFactory

pack-priv final Function<? super T, ? extends V>
valueSelector

Inherited from io.reactivex.internal.operators.flowable.AbstractFlowableWithUpstream:
source

Constructor Summary

AccessConstructor and Description
public
FlowableGroupBy(Flowable<T> source, Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, int bufferSize, boolean delayError, Function<? super Consumer<Object>, ? extends Map<K, Object>> mapFactory)

Method Summary

Modifier and TypeMethod and Description
protected void
subscribeActual(Subscriber<? super GroupedFlowable<K, V>>
the incoming Subscriber, never null
s)

Implements abstract io.reactivex.Flowable.subscribeActual.

Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming Subscribers.
Inherited from io.reactivex.internal.operators.flowable.AbstractFlowableWithUpstream:
source