Top Fields Constructors Methods
org.reactfx.util

pack-priv final Class AccumulativeStreamNotifications<T, A>

Located in compilation unit of org.reactfx.util.NotificationAccumulator.

extends NotificationAccumulatorBase<Consumer<? super T>, T, A>
Class Inheritance

Field Summary

Modifier and TypeField and 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

AccessConstructor and Description
pack-priv
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 TypeMethod and Description
protected Runnable
head(Consumer<? super T> observer, A accumulatedValue)

Implements abstract org.reactfx.util.NotificationAccumulatorBase.head.

public A
initialAccumulator(T value)

Implements org.reactfx.util.AccumulationFacility.initialAccumulator.

public A
reduce(A accum, T value)

Implements org.reactfx.util.AccumulationFacility.reduce.

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

Implements abstract org.reactfx.util.NotificationAccumulatorBase.size.

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

Implements abstract org.reactfx.util.NotificationAccumulatorBase.tail.

Inherited from org.reactfx.util.NotificationAccumulatorBase:
addAllcleargetAccumulationFacilityisEmptytakeOne

Field Detail

initialTransformationback to summary
private final Function<? super T, ? extends A> initialTransformation
reductionback to summary
private final BiFunction<? super A, ? super T, ? extends A> reduction
sizeback to summary
private final Function<? super A, AccumulatorSize> size
tailback to summary
private final Function<? super A, ? extends A> tail

Constructor Detail

AccumulativeStreamNotificationsback to summary
pack-priv 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 Detail

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

Implements abstract org.reactfx.util.NotificationAccumulatorBase.head.

Annotations
@Override
initialAccumulatorback to summary
public A initialAccumulator(T value)

Implements org.reactfx.util.AccumulationFacility.initialAccumulator.

Annotations
@Override
reduceback to summary
public A reduce(A accum, T value)

Implements org.reactfx.util.AccumulationFacility.reduce.

Annotations
@Override
sizeback to summary
protected AccumulatorSize size(Consumer<? super T> observer, A accumulatedValue)

Implements abstract org.reactfx.util.NotificationAccumulatorBase.size.

Annotations
@Override
tailback to summary
protected A tail(Consumer<? super T> observer, A accumulatedValue)

Implements abstract org.reactfx.util.NotificationAccumulatorBase.tail.

Annotations
@Override