Package org.reactfx.util
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 org.reactfx.util.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 -
Method Summary
Modifier and TypeMethodDescriptionprotected 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 org.reactfx.util.NotificationAccumulatorBase
addAll, clear, getAccumulationFacility, isEmpty, takeOne
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.reactfx.util.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 classNotificationAccumulatorBase<LiveList.Observer<? super E,
?>, QuasiListChange<? extends E>, ListModificationSequence<E>>
-
head
- Specified by:
head
in classNotificationAccumulatorBase<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 classNotificationAccumulatorBase<LiveList.Observer<? super E,
?>, QuasiListChange<? extends E>, ListModificationSequence<E>>
-