Class NonAccumulativeStreamNotifications<T>

    • Constructor Detail

      • NonAccumulativeStreamNotifications

        NonAccumulativeStreamNotifications()
    • Method Detail

      • head

        protected 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 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>