Package org.reactfx.util
Class ReducingStreamNotifications<T>
- java.lang.Object
-
- org.reactfx.util.NotificationAccumulatorBase<java.util.function.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<java.util.function.Consumer<? super T>,T,T>
final class ReducingStreamNotifications<T> extends AbstractReducingStreamNotifications<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>
-
-
Constructor Summary
Constructors Constructor Description ReducingStreamNotifications(java.util.function.BinaryOperator<T> reduction)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description T
reduce(T accum, T value)
-
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
-
-