org.reactfx.util

pack-priv abstract Class AbstractReducingStreamNotifications<T>

Class Inheritance

All Implemented Interfaces

Known Direct Subclasses

Constructor Summary

Access	Constructor and Description
pack-priv	AbstractReducingStreamNotifications()

Modifier and Type	Method and Description
protected final Runnable	head(Consumer<? super T> observer, T accumulatedValue) Implements abstract org.reactfx.util.NotificationAccumulatorBase.head.
protected final AccumulatorSize	size(Consumer<? super T> observer, T accumulatedValue) Implements abstract org.reactfx.util.NotificationAccumulatorBase.size.
protected final T	tail(Consumer<? super T> observer, T accumulatedValue) Implements abstract org.reactfx.util.NotificationAccumulatorBase.tail.

Inherited from org.reactfx.util.NotificationAccumulatorBase:: addAll clear getAccumulationFacility isEmpty takeOne

AbstractReducingStreamNotifications	back to summary
pack-priv AbstractReducingStreamNotifications()

head	back to summary
protected final Runnable head(Consumer<? super T> observer, T accumulatedValue) Implements abstract org.reactfx.util.NotificationAccumulatorBase.head. Annotations @Override

head

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

Annotations

size	back to summary
protected final AccumulatorSize size(Consumer<? super T> observer, T accumulatedValue) Implements abstract org.reactfx.util.NotificationAccumulatorBase.size. Annotations @Override

size

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

Annotations

tail	back to summary
protected final T tail(Consumer<? super T> observer, T accumulatedValue) Implements abstract org.reactfx.util.NotificationAccumulatorBase.tail. Annotations @Override

tail

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

Annotations