Package org.reactfx

Class AccumulateBetweenStream<T,​A>

    • Field Detail

      • initialTransformation

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

        private final java.util.function.BiFunction<? super A,​? super T,​? extends A> accumulation
      • deconstruction

        private final java.util.function.Function<? super A,​java.util.List<T>> deconstruction
      • hasValue

        private boolean hasValue
      • accum

        private A accum
    • Constructor Detail

      • AccumulateBetweenStream

        public AccumulateBetweenStream​(EventStream<T> source,
                                       EventStream<?> ticks,
                                       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,​java.util.List<T>> deconstruction)
    • Method Detail

      • observeInputs

        protected Subscription observeInputs()
        Description copied from class: ObservableBase
        Starts observing this observable's input(s), if any. This method is called when the number of observers goes from 0 to 1. This method is called before ObservableBase.newObserver(Object) is called for the first observer.
        Specified by:
        observeInputs in class ObservableBase<java.util.function.Consumer<? super T>,​T>
        Returns:
        subscription used to stop observing inputs. The subscription is unsubscribed (i.e. input observation stops) when the number of observers goes down to 0.
      • handleEvent

        private void handleEvent​(T event)
      • handleTick

        private void handleTick​(java.lang.Object tick)
      • reset

        private void reset()