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 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> -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
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
-
Field Details
-
accuMap
-
-
Constructor Details
-
NotificationAccumulatorBase
NotificationAccumulatorBase()
-
-
Method Details
-
size
-
head
-
tail
-
getAccumulationFacility
- Specified by:
getAccumulationFacility
in interfaceNotificationAccumulator<O,
V, A>
-
isEmpty
public boolean isEmpty()- Specified by:
isEmpty
in interfaceNotificationAccumulator<O,
V, A>
-
takeOne
- Specified by:
takeOne
in interfaceNotificationAccumulator<O,
V, A>
-
addAll
- Specified by:
addAll
in interfaceNotificationAccumulator<O,
V, A>
-
clear
public void clear()- Specified by:
clear
in interfaceNotificationAccumulator<O,
V, A>
-