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<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	addAll(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<Consumer<? super T>, T, T>	nonAccumulativeStreamNotifications()
static <T> NotificationAccumulator<Consumer<? super T>, T, Deque<T>>	queuingStreamNotifications()
static <T> NotificationAccumulator<Consumer<? super T>, T, T>	reducingStreamNotifications(BinaryOperator<T> reduction)
static <T> NotificationAccumulator<Consumer<? super T>, T, T>	retainLatestStreamNotifications()
static <T> NotificationAccumulator<Consumer<? super T>, T, T>	retainOldestValNotifications()
Runnable	takeOne()

Method Details

accumulativeStreamNotifications

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)

queuingStreamNotifications

static <T>
NotificationAccumulator<Consumer<? super T>, T, Deque<T>> queuingStreamNotifications()

reducingStreamNotifications

static <T>
NotificationAccumulator<Consumer<? super T>, T, T> reducingStreamNotifications(BinaryOperator<T> reduction)

retainLatestStreamNotifications

static <T>
NotificationAccumulator<Consumer<? super T>, T, T> retainLatestStreamNotifications()

retainOldestValNotifications

static <T>
NotificationAccumulator<Consumer<? super T>, T, T> retainOldestValNotifications()

nonAccumulativeStreamNotifications

static <T>
NotificationAccumulator<Consumer<? super T>, T, T> nonAccumulativeStreamNotifications()

listNotifications

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

isEmpty

boolean isEmpty()

takeOne

Runnable takeOne()

addAll

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

clear

void clear()

getAccumulationFacility

AccumulationFacility<V,A> getAccumulationFacility()