Interface NotificationAccumulator<O,​V,​A>

    • Method Detail

      • accumulativeStreamNotifications

        static <T,​A> NotificationAccumulator<java.util.function.Consumer<? super T>,​T,​A> 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)
      • queuingStreamNotifications

        static <T> NotificationAccumulator<java.util.function.Consumer<? super T>,​T,​java.util.Deque<T>> queuingStreamNotifications()
      • reducingStreamNotifications

        static <T> NotificationAccumulator<java.util.function.Consumer<? super T>,​T,​T> reducingStreamNotifications​(java.util.function.BinaryOperator<T> reduction)
      • retainLatestStreamNotifications

        static <T> NotificationAccumulator<java.util.function.Consumer<? super T>,​T,​T> retainLatestStreamNotifications()
      • retainOldestValNotifications

        static <T> NotificationAccumulator<java.util.function.Consumer<? super T>,​T,​T> retainOldestValNotifications()
      • nonAccumulativeStreamNotifications

        static <T> NotificationAccumulator<java.util.function.Consumer<? super T>,​T,​T> nonAccumulativeStreamNotifications()
      • isEmpty

        boolean isEmpty()
      • takeOne

        java.lang.Runnable takeOne()
      • addAll

        void addAll​(java.util.Iterator<O> observers,
                    V value)
      • clear

        void clear()