Uses of Class
io.reactivex.rxjava3.internal.operators.flowable.FlowableGroupBy.GroupedUnicast
-
Packages that use FlowableGroupBy.GroupedUnicast Package Description io.reactivex.rxjava3.internal.operators.flowable -
-
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.GroupedUnicast Modifier and Type Field Description (package private) java.util.Queue<FlowableGroupBy.GroupedUnicast<K,V>>
FlowableGroupBy.EvictionAction. evictedGroups
(package private) java.util.Queue<FlowableGroupBy.GroupedUnicast<K,V>>
FlowableGroupBy.GroupBySubscriber. evictedGroups
(package private) java.util.Map<java.lang.Object,FlowableGroupBy.GroupedUnicast<K,V>>
FlowableGroupBy.GroupBySubscriber. groups
Methods in io.reactivex.rxjava3.internal.operators.flowable that return FlowableGroupBy.GroupedUnicast Modifier and Type Method Description static <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.GroupedUnicast Modifier and Type Method Description void
FlowableGroupBy.EvictionAction. accept(FlowableGroupBy.GroupedUnicast<K,V> value)
Constructor parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type FlowableGroupBy.GroupedUnicast Constructor Description EvictionAction(java.util.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, java.util.Map<java.lang.Object,FlowableGroupBy.GroupedUnicast<K,V>> groups, java.util.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, java.util.Map<java.lang.Object,FlowableGroupBy.GroupedUnicast<K,V>> groups, java.util.Queue<FlowableGroupBy.GroupedUnicast<K,V>> evictedGroups)
-