Interface AccumulationFacility.Queuing<T>

All Superinterfaces:

AccumulationFacility<T,Deque<T>>

All Known Implementing Classes:

QueuingStreamNotifications

Enclosing interface:

AccumulationFacility<T,A>

public static interface AccumulationFacility.Queuing<T>
extends AccumulationFacility<T,Deque<T>>

Nested Class Summary

Nested classes/interfaces inherited from interface 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

Modifier and Type	Method	Description
default Deque<T>	initialAccumulator(T value)
default Deque<T>	reduce(Deque<T> accum, T value)

Method Details

initialAccumulator

default Deque<T> initialAccumulator(T value)

Specified by:

initialAccumulator in interface AccumulationFacility<T,Deque<T>>

reduce

default Deque<T> reduce(Deque<T> accum,
 T value)

Specified by:

reduce in interface AccumulationFacility<T,Deque<T>>