Package org.reactfx

Class AccumulateUntilLaterStream<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
      • eventThreadExecutor

        private final java.util.concurrent.Executor eventThreadExecutor
      • hasValue

        private boolean hasValue
      • accum

        private A accum
    • Constructor Detail

      • AccumulateUntilLaterStream

        public AccumulateUntilLaterStream​(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,​java.util.List<T>> deconstruction,
                                          java.util.concurrent.Executor eventThreadExecutor)
    • 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)
      • emitAccum

        private void emitAccum()