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 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

Modifier and Type	Field	Description
private AccuMap<O,V,A>	accuMap

Constructor Summary

Constructors

Constructor	Description
NotificationAccumulatorBase()

Method Summary

Modifier and Type	Method	Description
void	addAll(Iterator<O> keys, V value)
void	clear()
AccumulationFacility<V,A>	getAccumulationFacility()
protected abstract Runnable	head(O observer, A accumulatedValue)
boolean	isEmpty()
protected abstract AccumulatorSize	size(O observer, A accumulatedValue)
protected abstract A	tail(O observer, A accumulatedValue)
Runnable	takeOne()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface AccumulationFacility

initialAccumulator, reduce

Field Details

accuMap

private AccuMap<O,V,A> accuMap

Constructor Details

NotificationAccumulatorBase

NotificationAccumulatorBase()

Method Details

size

protected abstract AccumulatorSize size(O observer,
 A accumulatedValue)

head

protected abstract Runnable head(O observer,
 A accumulatedValue)

tail

protected abstract A tail(O observer,
 A accumulatedValue)

getAccumulationFacility

public AccumulationFacility<V,A> getAccumulationFacility()

Specified by:

getAccumulationFacility in interface NotificationAccumulator<O,V,A>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface NotificationAccumulator<O,V,A>

takeOne

public Runnable takeOne()

Specified by:

takeOne in interface NotificationAccumulator<O,V,A>

addAll

public void addAll(Iterator<O> keys,
 V value)

Specified by:

addAll in interface NotificationAccumulator<O,V,A>

clear

public void clear()

Specified by:

clear in interface NotificationAccumulator<O,V,A>