Class AbstractReducingStreamNotifications<T>

    • Constructor Detail

      • AbstractReducingStreamNotifications

        AbstractReducingStreamNotifications()
    • Method Detail

      • head

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

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