Package org.reactfx.util
Class AbstractReducingStreamNotifications<T>
- java.lang.Object
-
- org.reactfx.util.NotificationAccumulatorBase<java.util.function.Consumer<? super T>,T,T>
-
- org.reactfx.util.AbstractReducingStreamNotifications<T>
-
- All Implemented Interfaces:
AccumulationFacility<T,T>
,AccumulationFacility.HomotypicAccumulation<T>
,NotificationAccumulator<java.util.function.Consumer<? super T>,T,T>
- Direct Known Subclasses:
ReducingStreamNotifications
,RetailOldestValNotifications
,RetainLatestStreamNotifications
abstract class AbstractReducingStreamNotifications<T> extends NotificationAccumulatorBase<java.util.function.Consumer<? super T>,T,T> implements AccumulationFacility.HomotypicAccumulation<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 AbstractReducingStreamNotifications()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.lang.Runnable
head(java.util.function.Consumer<? super T> observer, T accumulatedValue)
protected AccumulatorSize
size(java.util.function.Consumer<? super T> observer, T accumulatedValue)
protected T
tail(java.util.function.Consumer<? super T> observer, T accumulatedValue)
-
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
reduce
-
Methods inherited from interface org.reactfx.util.AccumulationFacility.HomotypicAccumulation
initialAccumulator
-
-
-
-
Method Detail
-
size
protected final AccumulatorSize size(java.util.function.Consumer<? super T> observer, T accumulatedValue)
- Specified by:
size
in classNotificationAccumulatorBase<java.util.function.Consumer<? super T>,T,T>
-
head
protected final java.lang.Runnable head(java.util.function.Consumer<? super T> observer, T accumulatedValue)
- Specified by:
head
in classNotificationAccumulatorBase<java.util.function.Consumer<? super T>,T,T>
-
-