Class AccumulativeStreamNotifications<T,​A>

    • Field Detail

      • size

        private final java.util.function.Function<? super A,​AccumulatorSize> size
      • head

        private final java.util.function.Function<? super A,​? extends T> head
      • tail

        private final java.util.function.Function<? super A,​? extends A> tail
      • initialTransformation

        private final java.util.function.Function<? super T,​? extends A> initialTransformation
      • reduction

        private final java.util.function.BiFunction<? super A,​? super T,​? extends A> reduction
    • Constructor Detail

      • AccumulativeStreamNotifications

        AccumulativeStreamNotifications​(java.util.function.Function<? super A,​AccumulatorSize> size,
                                        java.util.function.Function<? super A,​? extends T> head,
                                        java.util.function.Function<? super A,​? extends A> tail,
                                        java.util.function.Function<? super T,​? extends A> initialTransformation,
                                        java.util.function.BiFunction<? super A,​? super T,​? extends A> reduction)
    • Method Detail

      • head

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

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

        public A initialAccumulator​(T value)
      • reduce

        public A reduce​(A accum,
                        T value)