NotificationAccumulatorBase

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>

Field Summary

Fields
Modifier and Type Field Description

private AccuMap<O,V,A> accuMap

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

Field Detail
- accuMap
```
private AccuMap<O,V,A> accuMap
```

Constructor Detail
- NotificationAccumulatorBase
```
NotificationAccumulatorBase()
```

Method Detail

size

protected abstract AccumulatorSize size(O observer,
                                        A accumulatedValue)

head

protected abstract java.lang.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 java.lang.Runnable takeOne()
```
Specified by:

takeOne in interface NotificationAccumulator<O,V,A>

addAll

public void addAll(java.util.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>