Package org.reactfx.util
Class QueuingStreamNotifications<T>
- java.lang.Object
-
- org.reactfx.util.NotificationAccumulatorBase<java.util.function.Consumer<? super T>,T,java.util.Deque<T>>
-
- org.reactfx.util.QueuingStreamNotifications<T>
-
- All Implemented Interfaces:
AccumulationFacility<T,java.util.Deque<T>>
,AccumulationFacility.Queuing<T>
,NotificationAccumulator<java.util.function.Consumer<? super T>,T,java.util.Deque<T>>
final class QueuingStreamNotifications<T> extends NotificationAccumulatorBase<java.util.function.Consumer<? super T>,T,java.util.Deque<T>> implements AccumulationFacility.Queuing<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 QueuingStreamNotifications()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.lang.Runnable
head(java.util.function.Consumer<? super T> observer, java.util.Deque<T> accumulatedValue)
protected AccumulatorSize
size(java.util.function.Consumer<? super T> observer, java.util.Deque<T> accumulatedValue)
protected java.util.Deque<T>
tail(java.util.function.Consumer<? super T> observer, java.util.Deque<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.Queuing
initialAccumulator, reduce
-
-
-
-
Method Detail
-
size
protected AccumulatorSize size(java.util.function.Consumer<? super T> observer, java.util.Deque<T> accumulatedValue)
- Specified by:
size
in classNotificationAccumulatorBase<java.util.function.Consumer<? super T>,T,java.util.Deque<T>>
-
head
protected java.lang.Runnable head(java.util.function.Consumer<? super T> observer, java.util.Deque<T> accumulatedValue)
- Specified by:
head
in classNotificationAccumulatorBase<java.util.function.Consumer<? super T>,T,java.util.Deque<T>>
-
-