Package org.reactfx.util
Class AccumulativeStreamNotifications<T,A>
- java.lang.Object
-
- org.reactfx.util.NotificationAccumulatorBase<java.util.function.Consumer<? super T>,T,A>
-
- org.reactfx.util.AccumulativeStreamNotifications<T,A>
-
- All Implemented Interfaces:
AccumulationFacility<T,A>
,NotificationAccumulator<java.util.function.Consumer<? super T>,T,A>
final class AccumulativeStreamNotifications<T,A> extends NotificationAccumulatorBase<java.util.function.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
Fields Modifier and Type Field Description private java.util.function.Function<? super A,? extends T>
head
private java.util.function.Function<? super T,? extends A>
initialTransformation
private java.util.function.BiFunction<? super A,? super T,? extends A>
reduction
private java.util.function.Function<? super A,AccumulatorSize>
size
private java.util.function.Function<? super A,? extends A>
tail
-
Constructor Summary
Constructors Constructor Description AccumulativeStreamNotifications(java.util.function.Function<? super A,AccumulatorSize> size, java.util.function.Function<? super A,? extends T> head, java.util.function.Function<? super A,? extends A> tail, java.util.function.Function<? super T,? extends A> initialTransformation, java.util.function.BiFunction<? super A,? super T,? extends A> reduction)
-
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, A accumulatedValue)
A
initialAccumulator(T value)
A
reduce(A accum, T value)
protected AccumulatorSize
size(java.util.function.Consumer<? super T> observer, A accumulatedValue)
protected A
tail(java.util.function.Consumer<? super T> observer, A accumulatedValue)
-
Methods inherited from class org.reactfx.util.NotificationAccumulatorBase
addAll, clear, getAccumulationFacility, isEmpty, takeOne
-
-
-
-
Field Detail
-
size
private final java.util.function.Function<? super A,AccumulatorSize> size
-
initialTransformation
private final java.util.function.Function<? super T,? extends A> initialTransformation
-
-
Constructor Detail
-
AccumulativeStreamNotifications
AccumulativeStreamNotifications(java.util.function.Function<? super A,AccumulatorSize> size, java.util.function.Function<? super A,? extends T> head, java.util.function.Function<? super A,? extends A> tail, java.util.function.Function<? super T,? extends A> initialTransformation, java.util.function.BiFunction<? super A,? super T,? extends A> reduction)
-
-
Method Detail
-
size
protected AccumulatorSize size(java.util.function.Consumer<? super T> observer, A accumulatedValue)
- Specified by:
size
in classNotificationAccumulatorBase<java.util.function.Consumer<? super T>,T,A>
-
head
protected java.lang.Runnable head(java.util.function.Consumer<? super T> observer, A accumulatedValue)
- Specified by:
head
in classNotificationAccumulatorBase<java.util.function.Consumer<? super T>,T,A>
-
tail
protected A tail(java.util.function.Consumer<? super T> observer, A accumulatedValue)
- Specified by:
tail
in classNotificationAccumulatorBase<java.util.function.Consumer<? super T>,T,A>
-
-