Class FlatMapped<T,U,O extends javafx.beans.value.ObservableValue<U>>

java.lang.Object
org.reactfx.ObservableBase<Consumer<? super U>,U>
org.reactfx.value.ValBase<U>
org.reactfx.value.FlatMapped<T,U,O>
All Implemented Interfaces:
javafx.beans.Observable, javafx.beans.value.ObservableValue<U>, Observable<Consumer<? super U>>, ProperObservable<Consumer<? super U>,U>, ProperVal<U>, Val<U>
Direct Known Subclasses:
FlatMappedVal, FlatMappedVar

abstract class FlatMapped<T,U,O extends javafx.beans.value.ObservableValue<U>> extends ValBase<U>
  • Field Details

    • src

      final Val<O extends javafx.beans.value.ObservableValue<U>> src
    • selectedSubscription

      private Subscription selectedSubscription
  • Constructor Details

    • FlatMapped

      public FlatMapped(javafx.beans.value.ObservableValue<T> src, Function<? super T,O> f)
  • Method Details

    • connect

      protected final Subscription connect()
      Description copied from class: ValBase
      Implementation of this method should start observing inputs. If the value of this Val may change as a result of input change, the corresponding input observer should call ValBase.invalidate() to notify observers of this Val. By the time of calling ValBase.invalidate(), the input observer must have already updated any internal state of this Val, so that a subsequent call to ValBase.computeValue() returns the current value of this Val.
      Specified by:
      connect in class ValBase<U>
      Returns:
      Subscription that can be used to stop observing inputs.
    • computeValue

      protected final U computeValue()
      Specified by:
      computeValue in class ValBase<U>
    • startObservingSelected

      private void startObservingSelected()
    • stopObservingSelected

      private void stopObservingSelected()
    • selectedInvalidated

      private void selectedInvalidated()
    • srcInvalidated

      private void srcInvalidated()