Class FlowableGroupBy.EvictionAction<K,V>
java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableGroupBy.EvictionAction<K,V>
- All Implemented Interfaces:
Consumer<FlowableGroupBy.GroupedUnicast<K,
V>>
- Enclosing class:
FlowableGroupBy<T,
K, V>
static final class FlowableGroupBy.EvictionAction<K,V>
extends Object
implements Consumer<FlowableGroupBy.GroupedUnicast<K,V>>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final Queue
<FlowableGroupBy.GroupedUnicast<K, V>> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
accept
(FlowableGroupBy.GroupedUnicast<K, V> value) Consume the given value.
-
Field Details
-
evictedGroups
-
-
Constructor Details
-
EvictionAction
EvictionAction(Queue<FlowableGroupBy.GroupedUnicast<K, V>> evictedGroups)
-
-
Method Details