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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

size

private final java.util.function.Function<? super A,AccumulatorSize> size

head

private final java.util.function.Function<? super A,? extends T> head

tail

private final java.util.function.Function<? super A,? extends A> tail

initialTransformation

private final java.util.function.Function<? super T,? extends A> initialTransformation

reduction

private final java.util.function.BiFunction<? super A,? super T,? extends A> reduction

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 class NotificationAccumulatorBase<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 class NotificationAccumulatorBase<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 class NotificationAccumulatorBase<java.util.function.Consumer<? super T>,T,A>

initialAccumulator

public A initialAccumulator(T value)

reduce

public A reduce(A accum,
                T value)