Package org.reactfx.util
Class NonAccumulativeStreamNotifications<T>
java.lang.Object
org.reactfx.util.NotificationAccumulatorBase<Consumer<? super T>,T,T>
org.reactfx.util.NonAccumulativeStreamNotifications<T>
- All Implemented Interfaces:
AccumulationFacility<T,
,T> AccumulationFacility.HomotypicAccumulation<T>
,AccumulationFacility.IllegalAccumulation<T,
,T> AccumulationFacility.NoAccumulation<T>
,NotificationAccumulator<Consumer<? super T>,
T, T>
final class NonAccumulativeStreamNotifications<T>
extends NotificationAccumulatorBase<Consumer<? super T>,T,T>
implements AccumulationFacility.NoAccumulation<T>
-
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
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.HomotypicAccumulation
initialAccumulator
Methods inherited from interface org.reactfx.util.AccumulationFacility.IllegalAccumulation
reduce
-
Constructor Details
-
NonAccumulativeStreamNotifications
NonAccumulativeStreamNotifications()
-
-
Method Details