Package org.reactfx

Class StateStream<S>

All Implemented Interfaces:
EventStream<S>, Observable<Consumer<? super S>>, ProperEventStream<S>, ProperObservable<Consumer<? super S>,S>

class StateStream<S> extends EventStreamBase<S>
  • Field Details

    • inputHandlers

      private final InputHandler[] inputHandlers
    • state

      private S state
  • 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 S>,S>
      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(Function<S,S> transition)