Package org.reactfx.util
Class ReducingStreamNotifications<T>
java.lang.Object
org.reactfx.util.NotificationAccumulatorBase<Consumer<? super T>,T,T>
org.reactfx.util.AbstractReducingStreamNotifications<T>
org.reactfx.util.ReducingStreamNotifications<T>
- All Implemented Interfaces:
AccumulationFacility<T,
,T> AccumulationFacility.HomotypicAccumulation<T>
,NotificationAccumulator<Consumer<? super T>,
T, 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> -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Methods inherited from class org.reactfx.util.AbstractReducingStreamNotifications
head, size, tail
Methods inherited from class org.reactfx.util.NotificationAccumulatorBase
addAll, clear, getAccumulationFacility, isEmpty, takeOne
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.reactfx.util.AccumulationFacility.HomotypicAccumulation
initialAccumulator
-
Field Details
-
reduction
-
-
Constructor Details
-
ReducingStreamNotifications
ReducingStreamNotifications(BinaryOperator<T> reduction)
-
-
Method Details
-
reduce
-