Package org.reactfx

Class StatefulStream<S,​O>

    • Field Detail

      • inputHandlers

        private final java.util.List<InputHandler> inputHandlers
      • state

        private S state
    • 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 O>,​O>
        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.
      • handleTransition

        private void handleTransition​(java.util.function.Function<S,​S> transition)
      • handleEmission

        private void handleEmission​(java.util.function.Function<S,​java.util.Optional<O>> emission)
      • handleTransmission

        private void handleTransmission​(java.util.function.Function<S,​Tuple2<S,​java.util.Optional<O>>> transmission)