Class QueuingStreamNotifications<T>

java.lang.Object
org.reactfx.util.NotificationAccumulatorBase<Consumer<? super T>,T,Deque<T>>
org.reactfx.util.QueuingStreamNotifications<T>
All Implemented Interfaces:
AccumulationFacility<T,Deque<T>>, AccumulationFacility.Queuing<T>, NotificationAccumulator<Consumer<? super T>,T,Deque<T>>

final class QueuingStreamNotifications<T> extends NotificationAccumulatorBase<Consumer<? super T>,T,Deque<T>> implements AccumulationFacility.Queuing<T>