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 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 final Function<? super A, ? extends T>	head
private final Function<? super T, ? extends A>	initialTransformation
private final BiFunction<? super A, ? super T, ? extends A>	reduction
private final Function<? super A, AccumulatorSize>	size
private final Function<? super A, ? extends A>	tail

Constructor Summary

Constructors

Constructor	Description
AccumulativeStreamNotifications(Function<? super A, AccumulatorSize> size, Function<? super A, ? extends T> head, Function<? super A, ? extends A> tail, Function<? super T, ? extends A> initialTransformation, BiFunction<? super A, ? super T, ? extends A> reduction)

Method Summary

Modifier and Type	Method	Description
protected Runnable	head(Consumer<? super T> observer, A accumulatedValue)
A	initialAccumulator(T value)
A	reduce(A accum, T value)
protected AccumulatorSize	size(Consumer<? super T> observer, A accumulatedValue)
protected A	tail(Consumer<? super T> observer, A accumulatedValue)

Methods inherited from class NotificationAccumulatorBase

addAll, clear, getAccumulationFacility, isEmpty, takeOne

Methods inherited from class Object

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

Field Details

size

private final Function<? super A, AccumulatorSize> size

head

private final Function<? super A, ? extends T> head

tail

private final Function<? super A, ? extends A> tail

initialTransformation

private final Function<? super T, ? extends A> initialTransformation

reduction

private final BiFunction<? super A, ? super T, ? extends A> reduction

Constructor Details

AccumulativeStreamNotifications

AccumulativeStreamNotifications(Function<? super A, AccumulatorSize> size,
 Function<? super A, ? extends T> head,
 Function<? super A, ? extends A> tail,
 Function<? super T, ? extends A> initialTransformation,
 BiFunction<? super A, ? super T, ? extends A> reduction)

Method Details

size

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

Specified by:

size in class NotificationAccumulatorBase<Consumer<? super T>, T, A>

head

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

Specified by:

head in class NotificationAccumulatorBase<Consumer<? super T>, T, A>

tail

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

Specified by:

tail in class NotificationAccumulatorBase<Consumer<? super T>, T, A>

initialAccumulator

public A initialAccumulator(T value)

reduce

public A reduce(A accum,
 T value)