Package org.reactfx.util

Interface NotificationAccumulator<O,V,A>

Type Parameters:

O - observer type

V - type of produced values

A - type of accumulated value

All Known Implementing Classes:

AbstractReducingStreamNotifications, AccumulativeStreamNotifications, ListNotifications, NonAccumulativeStreamNotifications, NotificationAccumulatorBase, QueuingStreamNotifications, ReducingStreamNotifications, RetailOldestValNotifications, RetainLatestStreamNotifications

public interface NotificationAccumulator<O,V,A>

Method Summary

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

Method Detail

accumulativeStreamNotifications

static <T,A> NotificationAccumulator<java.util.function.Consumer<? super T>,T,A> 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)

queuingStreamNotifications

static <T> NotificationAccumulator<java.util.function.Consumer<? super T>,T,java.util.Deque<T>> queuingStreamNotifications()

reducingStreamNotifications

static <T> NotificationAccumulator<java.util.function.Consumer<? super T>,T,T> reducingStreamNotifications(java.util.function.BinaryOperator<T> reduction)

retainLatestStreamNotifications

static <T> NotificationAccumulator<java.util.function.Consumer<? super T>,T,T> retainLatestStreamNotifications()

retainOldestValNotifications

static <T> NotificationAccumulator<java.util.function.Consumer<? super T>,T,T> retainOldestValNotifications()

nonAccumulativeStreamNotifications

static <T> NotificationAccumulator<java.util.function.Consumer<? super T>,T,T> nonAccumulativeStreamNotifications()

listNotifications

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

isEmpty

boolean isEmpty()

takeOne

java.lang.Runnable takeOne()

addAll

void addAll(java.util.Iterator<O> observers,
            V value)

clear

void clear()

getAccumulationFacility

AccumulationFacility<V,A> getAccumulationFacility()