Top Fields Constructors Methods
org.reactfx.util

pack-priv abstract Class NotificationAccumulatorBase<O, V, A>

Located in compilation unit of org.reactfx.util.NotificationAccumulator.

extends Object
implements NotificationAccumulator<O, V, A>, AccumulationFacility<V, A>
Class Inheritance
All Implemented Interfaces
org.reactfx.util.AccumulationFacility, org.reactfx.util.NotificationAccumulator
Known Direct Subclasses
org.reactfx.util.NonAccumulativeStreamNotifications, org.reactfx.util.AccumulativeStreamNotifications, org.reactfx.util.QueuingStreamNotifications, org.reactfx.util.AbstractReducingStreamNotifications, org.reactfx.util.ListNotifications

Field Summary

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

Constructor Summary

AccessConstructor and Description
pack-priv
NotificationAccumulatorBase()

Method Summary

Modifier and TypeMethod and Description
public void
addAll(Iterator<O> keys, V value)

Implements org.reactfx.util.NotificationAccumulator.addAll.

public void
clear()

Implements org.reactfx.util.NotificationAccumulator.clear.

public AccumulationFacility<V, A>
getAccumulationFacility()

Implements org.reactfx.util.NotificationAccumulator.getAccumulationFacility.

protected abstract Runnable
head(O observer, A accumulatedValue)

public boolean
isEmpty()

Implements org.reactfx.util.NotificationAccumulator.isEmpty.

protected abstract AccumulatorSize
size(O observer, A accumulatedValue)

protected abstract A
tail(O observer, A accumulatedValue)

public Runnable
takeOne()

Implements org.reactfx.util.NotificationAccumulator.takeOne.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

accuMapback to summary
private AccuMap<O, V, A> accuMap

Constructor Detail

NotificationAccumulatorBaseback to summary
pack-priv NotificationAccumulatorBase()

Method Detail

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

Implements org.reactfx.util.NotificationAccumulator.addAll.

Annotations
@Override
clearback to summary
public void clear()

Implements org.reactfx.util.NotificationAccumulator.clear.

Annotations
@Override
getAccumulationFacilityback to summary
public AccumulationFacility<V, A> getAccumulationFacility()

Implements org.reactfx.util.NotificationAccumulator.getAccumulationFacility.

Annotations
@Override
headback to summary
protected abstract Runnable head(O observer, A accumulatedValue)
isEmptyback to summary
public boolean isEmpty()

Implements org.reactfx.util.NotificationAccumulator.isEmpty.

Annotations
@Override
sizeback to summary
protected abstract AccumulatorSize size(O observer, A accumulatedValue)
tailback to summary
protected abstract A tail(O observer, A accumulatedValue)
takeOneback to summary
public Runnable takeOne()

Implements org.reactfx.util.NotificationAccumulator.takeOne.

Annotations
@Override