Interface AccumulationFacility<T,A>

All Known Subinterfaces:

AccumulationFacility.HomotypicAccumulation<T>, AccumulationFacility.IllegalAccumulation<T,A>, AccumulationFacility.ListChangeAccumulation<E>, AccumulationFacility.NoAccumulation<T>, AccumulationFacility.Queuing<T>, AccumulationFacility.RetainLatest<T>, AccumulationFacility.RetainOldest<T>

All Known Implementing Classes:

AbstractReducingStreamNotifications, AccumulativeStreamNotifications, ListNotifications, NonAccumulativeStreamNotifications, NotificationAccumulatorBase, QueuingStreamNotifications, ReducingStreamNotifications, RetailOldestValNotifications, RetainLatestStreamNotifications

public interface AccumulationFacility<T,A>

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	AccumulationFacility.HomotypicAccumulation<T>
static interface	AccumulationFacility.IllegalAccumulation<T,A>
static interface	AccumulationFacility.ListChangeAccumulation<E>
static interface	AccumulationFacility.NoAccumulation<T>
static interface	AccumulationFacility.Queuing<T>
static interface	AccumulationFacility.RetainLatest<T>
static interface	AccumulationFacility.RetainOldest<T>

Method Summary

Modifier and Type	Method	Description
A	initialAccumulator(T value)
A	reduce(A accum, T value)

Method Details

initialAccumulator

A initialAccumulator(T value)

reduce

A reduce(A accum,
 T value)