Uses of Class
io.reactivex.rxjava3.internal.operators.flowable.FlowableGroupBy.GroupedUnicast
Packages that use FlowableGroupBy.GroupedUnicast
-
Uses of FlowableGroupBy.GroupedUnicast in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type FlowableGroupBy.GroupedUnicastModifier and TypeFieldDescription(package private) final Queue
<FlowableGroupBy.GroupedUnicast<K, V>> FlowableGroupBy.EvictionAction.evictedGroups
(package private) final Queue
<FlowableGroupBy.GroupedUnicast<K, V>> FlowableGroupBy.GroupBySubscriber.evictedGroups
(package private) final Map
<Object, FlowableGroupBy.GroupedUnicast<K, V>> FlowableGroupBy.GroupBySubscriber.groups
Methods in io.reactivex.rxjava3.internal.operators.flowable that return FlowableGroupBy.GroupedUnicastModifier and TypeMethodDescriptionstatic <T,
K> FlowableGroupBy.GroupedUnicast <K, T> FlowableGroupBy.GroupedUnicast.createWith
(K key, int bufferSize, FlowableGroupBy.GroupBySubscriber<?, K, T> parent, boolean delayError) Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type FlowableGroupBy.GroupedUnicastModifier and TypeMethodDescriptionvoid
FlowableGroupBy.EvictionAction.accept
(FlowableGroupBy.GroupedUnicast<K, V> value) Constructor parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type FlowableGroupBy.GroupedUnicastModifierConstructorDescription(package private)
EvictionAction
(Queue<FlowableGroupBy.GroupedUnicast<K, V>> evictedGroups) 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) 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)