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 Constructor Description ListNotifications()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.lang.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 <O> java.lang.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
-
-
-
-
Method Detail
-
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
protected java.lang.Runnable head(LiveList.Observer<? super E,?> observer, ListModificationSequence<E> mods)
- Specified by:
head
in classNotificationAccumulatorBase<LiveList.Observer<? super E,?>,QuasiListChange<? extends E>,ListModificationSequence<E>>
-
takeHead
private final <O> java.lang.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>>
-
-