Package org.reactfx

Class AccumulativeEventStream<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
    • Constructor Detail

      • AccumulativeEventStream

        AccumulativeEventStream​(EventStream<T> source,
                                java.util.function.Function<? super T,​? extends A> initialTransformation,
                                java.util.function.BiFunction<? super A,​? super T,​? extends A> accumulation,
                                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)