Package org.reactfx.util
Class AccumulativeStreamNotifications<T,A>
java.lang.Object
org.reactfx.util.NotificationAccumulatorBase<Consumer<? super T>,T,A>
org.reactfx.util.AccumulativeStreamNotifications<T,A>
- All Implemented Interfaces:
AccumulationFacility<T,
,A> NotificationAccumulator<Consumer<? super T>,
T, A>
final class AccumulativeStreamNotifications<T,A>
extends NotificationAccumulatorBase<Consumer<? super T>,T,A>
-
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> -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final BiFunction
<? super A, ? super T, ? extends A> private final Function
<? super A, AccumulatorSize> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected Runnable
initialAccumulator
(T value) protected AccumulatorSize
protected A
Methods inherited from class org.reactfx.util.NotificationAccumulatorBase
addAll, clear, getAccumulationFacility, isEmpty, takeOne
-
Field Details
-
size
-
head
-
tail
-
initialTransformation
-
reduction
-
-
Constructor Details
-
AccumulativeStreamNotifications
-
-
Method Details