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>
  • Method Details

    • initialAccumulator

      A initialAccumulator(T value)
    • reduce

      A reduce(A accum, T value)