Top Constructors Methods
org.reactfx.util

pack-priv final Class NonAccumulativeStreamNotifications<T>

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

extends NotificationAccumulatorBase<Consumer<? super T>, T, T>
implements AccumulationFacility.NoAccumulation<T>
Class Inheritance
All Implemented Interfaces
org.reactfx.util.AccumulationFacility.NoAccumulation, org.reactfx.util.AccumulationFacility.HomotypicAccumulation, org.reactfx.util.AccumulationFacility, org.reactfx.util.AccumulationFacility.IllegalAccumulation

Constructor Summary

AccessConstructor and Description
pack-priv
NonAccumulativeStreamNotifications()

Method Summary

Modifier and TypeMethod and Description
protected Runnable
head(Consumer<? super T> observer, T accumulatedValue)

Implements abstract org.reactfx.util.NotificationAccumulatorBase.head.

protected AccumulatorSize
size(Consumer<? super T> observer, T accumulatedValue)

Implements abstract org.reactfx.util.NotificationAccumulatorBase.size.

protected T
tail(Consumer<? super T> observer, T accumulatedValue)

Implements abstract org.reactfx.util.NotificationAccumulatorBase.tail.

Inherited from org.reactfx.util.NotificationAccumulatorBase:
addAllcleargetAccumulationFacilityisEmptytakeOne

Constructor Detail

NonAccumulativeStreamNotificationsback to summary
pack-priv NonAccumulativeStreamNotifications()

Method Detail

headback to summary
protected Runnable head(Consumer<? super T> observer, T accumulatedValue)

Implements abstract org.reactfx.util.NotificationAccumulatorBase.head.

Annotations
@Override
sizeback to summary
protected AccumulatorSize size(Consumer<? super T> observer, T accumulatedValue)

Implements abstract org.reactfx.util.NotificationAccumulatorBase.size.

Annotations
@Override
tailback to summary
protected T tail(Consumer<? super T> observer, T accumulatedValue)

Implements abstract org.reactfx.util.NotificationAccumulatorBase.tail.

Annotations
@Override