Class NonAccumulativeStreamNotifications<T>

java.lang.Object

org.reactfx.util.NotificationAccumulatorBase<Consumer<? super T>, T, T>

org.reactfx.util.NonAccumulativeStreamNotifications<T>

All Implemented Interfaces:

AccumulationFacility<T,T>, AccumulationFacility.HomotypicAccumulation<T>, AccumulationFacility.IllegalAccumulation<T,T>, AccumulationFacility.NoAccumulation<T>, NotificationAccumulator<Consumer<? super T>, T, T>

final class NonAccumulativeStreamNotifications<T>
extends NotificationAccumulatorBase<Consumer<? super T>, T, T>
implements AccumulationFacility.NoAccumulation<T>

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>

Constructor Summary

Constructors

Constructor	Description
NonAccumulativeStreamNotifications()

Method Summary

Modifier and Type	Method	Description
protected Runnable	head(Consumer<? super T> observer, T accumulatedValue)
protected AccumulatorSize	size(Consumer<? super T> observer, T accumulatedValue)
protected T	tail(Consumer<? super T> observer, T accumulatedValue)

Methods inherited from class NotificationAccumulatorBase

addAll, clear, getAccumulationFacility, isEmpty, takeOne

Methods inherited from class Object

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

Methods inherited from interface AccumulationFacility.HomotypicAccumulation

initialAccumulator

Methods inherited from interface AccumulationFacility.IllegalAccumulation

reduce

Constructor Details

NonAccumulativeStreamNotifications

NonAccumulativeStreamNotifications()

Method Details

size

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

Specified by:

size in class NotificationAccumulatorBase<Consumer<? super T>, T, T>

head

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

Specified by:

head in class NotificationAccumulatorBase<Consumer<? super T>, T, T>

tail

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

Specified by:

tail in class NotificationAccumulatorBase<Consumer<? super T>, T, T>