Class ListNotifications<E>

java.lang.Object

org.reactfx.util.NotificationAccumulatorBase<LiveList.Observer<? super E, ?>, QuasiListChange<? extends E>, ListModificationSequence<E>>

org.reactfx.util.ListNotifications<E>

All Implemented Interfaces:

AccumulationFacility<QuasiListChange<? extends E>, ListModificationSequence<E>>, AccumulationFacility.ListChangeAccumulation<E>, NotificationAccumulator<LiveList.Observer<? super E, ?>, QuasiListChange<? extends E>, ListModificationSequence<E>>

final class ListNotifications<E>
extends NotificationAccumulatorBase<LiveList.Observer<? super E, ?>, QuasiListChange<? extends E>, ListModificationSequence<E>>
implements AccumulationFacility.ListChangeAccumulation<E>

Nested Class Summary

Nested classes/interfaces inherited from interface AccumulationFacility

AccumulationFacility.HomotypicAccumulation<T>, AccumulationFacility.IllegalAccumulation<T,A>, AccumulationFacility.ListChangeAccumulation<E>, AccumulationFacility.NoAccumulation<T>, AccumulationFacility.Queuing<T>, AccumulationFacility.RetainLatest<T>, AccumulationFacility.RetainOldest<T>

Constructor Summary

Constructors

Constructor	Description
ListNotifications()

Method Summary

Modifier and Type	Method	Description
protected Runnable	head(LiveList.Observer<? super E, ?> observer, ListModificationSequence<E> mods)
protected AccumulatorSize	size(LiveList.Observer<? super E, ?> observer, ListModificationSequence<E> accumulatedValue)
protected ListModificationSequence<E>	tail(LiveList.Observer<? super E, ?> observer, ListModificationSequence<E> mods)
private final <O> Runnable	takeHead(LiveList.Observer<? super E, O> observer, ListModificationSequence<E> mods)

Methods inherited from class NotificationAccumulatorBase

addAll, clear, getAccumulationFacility, isEmpty, takeOne

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface AccumulationFacility.ListChangeAccumulation

initialAccumulator, reduce

Constructor Details

ListNotifications

ListNotifications()

Method Details

size

protected AccumulatorSize size(LiveList.Observer<? super E, ?> observer,
 ListModificationSequence<E> accumulatedValue)

Specified by:

size in class NotificationAccumulatorBase<LiveList.Observer<? super E, ?>, QuasiListChange<? extends E>, ListModificationSequence<E>>

head

protected Runnable head(LiveList.Observer<? super E, ?> observer,
 ListModificationSequence<E> mods)

Specified by:

head in class NotificationAccumulatorBase<LiveList.Observer<? super E, ?>, QuasiListChange<? extends E>, ListModificationSequence<E>>

takeHead

private final <O> Runnable takeHead(LiveList.Observer<? super E, O> observer,
 ListModificationSequence<E> mods)

tail

protected ListModificationSequence<E> tail(LiveList.Observer<? super E, ?> observer,
 ListModificationSequence<E> mods)

Specified by:

tail in class NotificationAccumulatorBase<LiveList.Observer<? super E, ?>, QuasiListChange<? extends E>, ListModificationSequence<E>>