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 java.lang.Object implements Consumer<FlowableGroupBy.GroupedUnicast<K,V>>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) java.util.Queue<FlowableGroupBy.GroupedUnicast<K,V>>
evictedGroups
-
Constructor Summary
Constructors Constructor Description EvictionAction(java.util.Queue<FlowableGroupBy.GroupedUnicast<K,V>> evictedGroups)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
accept(FlowableGroupBy.GroupedUnicast<K,V> value)
Consume the given value.
-
-
-
Field Detail
-
evictedGroups
final java.util.Queue<FlowableGroupBy.GroupedUnicast<K,V>> evictedGroups
-
-
Constructor Detail
-
EvictionAction
EvictionAction(java.util.Queue<FlowableGroupBy.GroupedUnicast<K,V>> evictedGroups)
-
-