Package org.reactfx.util
Class NotificationAccumulatorBase<O,V,A>
- java.lang.Object
-
- org.reactfx.util.NotificationAccumulatorBase<O,V,A>
-
- All Implemented Interfaces:
AccumulationFacility<V,A>
,NotificationAccumulator<O,V,A>
- Direct Known Subclasses:
AbstractReducingStreamNotifications
,AccumulativeStreamNotifications
,ListNotifications
,NonAccumulativeStreamNotifications
,QueuingStreamNotifications
abstract class NotificationAccumulatorBase<O,V,A> extends java.lang.Object implements NotificationAccumulator<O,V,A>, AccumulationFacility<V,A>
-
-
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 NotificationAccumulatorBase()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
addAll(java.util.Iterator<O> keys, V value)
void
clear()
AccumulationFacility<V,A>
getAccumulationFacility()
protected abstract java.lang.Runnable
head(O observer, A accumulatedValue)
boolean
isEmpty()
protected abstract AccumulatorSize
size(O observer, A accumulatedValue)
protected abstract A
tail(O observer, A accumulatedValue)
java.lang.Runnable
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
initialAccumulator, reduce
-
-
-
-
Method Detail
-
size
protected abstract AccumulatorSize size(O observer, A accumulatedValue)
-
getAccumulationFacility
public AccumulationFacility<V,A> getAccumulationFacility()
- Specified by:
getAccumulationFacility
in interfaceNotificationAccumulator<O,V,A>
-
isEmpty
public boolean isEmpty()
- Specified by:
isEmpty
in interfaceNotificationAccumulator<O,V,A>
-
takeOne
public java.lang.Runnable takeOne()
- Specified by:
takeOne
in interfaceNotificationAccumulator<O,V,A>
-
addAll
public void addAll(java.util.Iterator<O> keys, V value)
- Specified by:
addAll
in interfaceNotificationAccumulator<O,V,A>
-
clear
public void clear()
- Specified by:
clear
in interfaceNotificationAccumulator<O,V,A>
-
-