Package org.reactfx.util

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

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 org.reactfx.util.NotificationAccumulatorBase

addAll, clear, getAccumulationFacility, isEmpty, 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.HomotypicAccumulation

initialAccumulator

Methods inherited from interface org.reactfx.util.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>