org.reactfx.util

pack-priv final Class QueuingStreamNotifications<T>

Class Inheritance

All Implemented Interfaces

Constructor Summary

Access	Constructor and Description
pack-priv	QueuingStreamNotifications()

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

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

QueuingStreamNotifications	back to summary
pack-priv QueuingStreamNotifications()

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

head

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

Annotations

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

size

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

Annotations

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

tail

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

Annotations