org.reactfx.util

public Interface NotificationAccumulator<O, V, A>

Additional top-level classes in compilation unit: NotificationAccumulatorBase, NonAccumulativeStreamNotifications, AccumulativeStreamNotifications, QueuingStreamNotifications, AbstractReducingStreamNotifications, ReducingStreamNotifications, RetainLatestStreamNotifications, RetailOldestValNotifications, ListNotifications.

Known Direct Implementers

org.reactfx.util.NotificationAccumulatorBase

Type Parameters

<O>: observer type
<V>: type of produced values
<A>: type of accumulated value

Imports

java.util.Deque, .Iterator, .NoSuchElementException, java.util.function.BiFunction, .BinaryOperator, .Consumer, .Function, org.reactfx.collection.ListModificationSequence, .LiveList, .LiveList.Observer, .QuasiListChange

Method Summary

Modifier and Type	Method and Description
public static <T, A> NotificationAccumulator<Consumer<? super T>, T, A>	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)
public void	addAll(Iterator<O> observers, V value)
public void	clear()
public AccumulationFacility<V, A>	getAccumulationFacility()
public boolean	isEmpty()
public static <E> NotificationAccumulator<LiveList.Observer<? super E, ?>, QuasiListChange<? extends E>, ListModificationSequence<E>>	listNotifications()
public static <T> NotificationAccumulator<Consumer<? super T>, T, T>	nonAccumulativeStreamNotifications()
public static <T> NotificationAccumulator<Consumer<? super T>, T, Deque<T>>	queuingStreamNotifications()
public static <T> NotificationAccumulator<Consumer<? super T>, T, T>	reducingStreamNotifications(BinaryOperator<T> reduction)
public static <T> NotificationAccumulator<Consumer<? super T>, T, T>	retainLatestStreamNotifications()
public static <T> NotificationAccumulator<Consumer<? super T>, T, T>	retainOldestValNotifications()
public Runnable	takeOne()

Method Detail

accumulativeStreamNotifications	back to summary
public static <T, A> NotificationAccumulator<Consumer<? super T>, T, A> 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)

addAll	back to summary
public void addAll(Iterator<O> observers, V value)

clear	back to summary
public void clear()

getAccumulationFacility	back to summary
public AccumulationFacility<V, A> getAccumulationFacility()

isEmpty	back to summary
public boolean isEmpty()

listNotifications	back to summary
public static <E> NotificationAccumulator<LiveList.Observer<? super E, ?>, QuasiListChange<? extends E>, ListModificationSequence<E>> listNotifications()

nonAccumulativeStreamNotifications	back to summary
public static <T> NotificationAccumulator<Consumer<? super T>, T, T> nonAccumulativeStreamNotifications()

queuingStreamNotifications	back to summary
public static <T> NotificationAccumulator<Consumer<? super T>, T, Deque<T>> queuingStreamNotifications()

reducingStreamNotifications	back to summary
public static <T> NotificationAccumulator<Consumer<? super T>, T, T> reducingStreamNotifications(BinaryOperator<T> reduction)

retainLatestStreamNotifications	back to summary
public static <T> NotificationAccumulator<Consumer<? super T>, T, T> retainLatestStreamNotifications()

retainOldestValNotifications	back to summary
public static <T> NotificationAccumulator<Consumer<? super T>, T, T> retainOldestValNotifications()

takeOne	back to summary
public Runnable takeOne()