Class QueuingStreamNotifications<T>

    • Constructor Detail

      • QueuingStreamNotifications

        QueuingStreamNotifications()
    • Method Detail

      • size

        protected AccumulatorSize size​(java.util.function.Consumer<? super T> observer,
                                       java.util.Deque<T> accumulatedValue)
        Specified by:
        size in class NotificationAccumulatorBase<java.util.function.Consumer<? super T>,​T,​java.util.Deque<T>>
      • head

        protected java.lang.Runnable head​(java.util.function.Consumer<? super T> observer,
                                          java.util.Deque<T> accumulatedValue)
        Specified by:
        head in class NotificationAccumulatorBase<java.util.function.Consumer<? super T>,​T,​java.util.Deque<T>>
      • tail

        protected java.util.Deque<T> tail​(java.util.function.Consumer<? super T> observer,
                                          java.util.Deque<T> accumulatedValue)
        Specified by:
        tail in class NotificationAccumulatorBase<java.util.function.Consumer<? super T>,​T,​java.util.Deque<T>>