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
Modifier and TypeMethodDescriptionstatic <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) void
void
clear()
boolean
isEmpty()
static <E> NotificationAccumulator
<LiveList.Observer<? super E, ?>, QuasiListChange<? extends E>, ListModificationSequence<E>> static <T> NotificationAccumulator
<Consumer<? super T>, T, T> static <T> NotificationAccumulator
<Consumer<? super T>, T, Deque<T>> static <T> NotificationAccumulator
<Consumer<? super T>, T, T> reducingStreamNotifications
(BinaryOperator<T> reduction) static <T> NotificationAccumulator
<Consumer<? super T>, T, T> static <T> NotificationAccumulator
<Consumer<? super T>, T, T> takeOne()
-
Method Details
-
accumulativeStreamNotifications
static <T,A> NotificationAccumulator<Consumer<? super T>,T, accumulativeStreamNotificationsA> (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) -
queuingStreamNotifications
-
reducingStreamNotifications
static <T> NotificationAccumulator<Consumer<? super T>,T, reducingStreamNotificationsT> (BinaryOperator<T> reduction) -
retainLatestStreamNotifications
-
retainOldestValNotifications
-
nonAccumulativeStreamNotifications
-
listNotifications
static <E> NotificationAccumulator<LiveList.Observer<? super E,?>, listNotifications()QuasiListChange<? extends E>, ListModificationSequence<E>> -
isEmpty
boolean isEmpty() -
takeOne
Runnable takeOne() -
addAll
-
clear
void clear() -
getAccumulationFacility
AccumulationFacility<V,A> getAccumulationFacility()
-