Class AbstractReducingStreamNotifications<T>

java.lang.Object

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

org.reactfx.util.AbstractReducingStreamNotifications<T>

All Implemented Interfaces:

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

Direct Known Subclasses:

ReducingStreamNotifications, RetailOldestValNotifications, RetainLatestStreamNotifications

abstract class AbstractReducingStreamNotifications<T>
extends NotificationAccumulatorBase<Consumer<? super T>, T, T>
implements AccumulationFacility.HomotypicAccumulation<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
AbstractReducingStreamNotifications()

Method Summary

Modifier and Type	Method	Description
protected final Runnable	head(Consumer<? super T> observer, T accumulatedValue)
protected final AccumulatorSize	size(Consumer<? super T> observer, T accumulatedValue)
protected final 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

reduce

Methods inherited from interface AccumulationFacility.HomotypicAccumulation

initialAccumulator

Constructor Details

AbstractReducingStreamNotifications

AbstractReducingStreamNotifications()

Method Details

size

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

Specified by:

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

head

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

Specified by:

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

tail

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

Specified by:

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