Package org.reactfx.util
Interface NotificationAccumulator<O,V,A>
-
- Type Parameters:
O
- observer typeV
- type of produced valuesA
- 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
All Methods Static Methods Instance Methods Abstract Methods 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()
-
clear
void clear()
-
getAccumulationFacility
AccumulationFacility<V,A> getAccumulationFacility()
-
-