Package org.reactfx

Class AccumulateUntilLaterStream<T,A>

java.lang.Object
org.reactfx.ObservableBase<Consumer<? super T>,T>
org.reactfx.EventStreamBase<T>
org.reactfx.AccumulateUntilLaterStream<T,A>
All Implemented Interfaces:
EventStream<T>, Observable<Consumer<? super T>>, ProperEventStream<T>, ProperObservable<Consumer<? super T>,T>

class AccumulateUntilLaterStream<T,A> extends EventStreamBase<T>
  • Field Details

    • source

      private final EventStream<T> source
    • initialTransformation

      private final Function<? super T,? extends A> initialTransformation
    • accumulation

      private final BiFunction<? super A,? super T,? extends A> accumulation
    • deconstruction

      private final Function<? super A,List<T>> deconstruction
    • eventThreadExecutor

      private final Executor eventThreadExecutor
    • hasValue

      private boolean hasValue
    • accum

      private A accum
  • Constructor Details

  • Method Details

    • 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<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()