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

Classes in io.reactivex.rxjava3.internal.operators.flowable that implement interfaces with type arguments of type FlowableGroupBy.GroupedUnicast

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

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

Modifier and Type	Field	Description
(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.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

Modifier	Constructor	Description
(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)