Package org.reactfx.util
Interface AccumulationFacility.Queuing<T>
-
- All Superinterfaces:
AccumulationFacility<T,java.util.Deque<T>>
- All Known Implementing Classes:
QueuingStreamNotifications
- Enclosing interface:
- AccumulationFacility<T,A>
public static interface AccumulationFacility.Queuing<T> extends AccumulationFacility<T,java.util.Deque<T>>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.reactfx.util.AccumulationFacility
AccumulationFacility.HomotypicAccumulation<T>, AccumulationFacility.IllegalAccumulation<T,A>, AccumulationFacility.ListChangeAccumulation<E>, AccumulationFacility.NoAccumulation<T>, AccumulationFacility.Queuing<T>, AccumulationFacility.RetainLatest<T>, AccumulationFacility.RetainOldest<T>
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default java.util.Deque<T>
initialAccumulator(T value)
default java.util.Deque<T>
reduce(java.util.Deque<T> accum, T value)
-
-
-
Method Detail
-
initialAccumulator
default java.util.Deque<T> initialAccumulator(T value)
- Specified by:
initialAccumulator
in interfaceAccumulationFacility<T,java.util.Deque<T>>
-
-