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 Summary

Fields

Modifier and Type	Field	Description
private Subscription	selectedSubscription
(package private) final Val<O>	src

Constructor Summary

Constructors

Constructor	Description
FlatMapped(javafx.beans.value.ObservableValue<T> src, Function<? super T, O> f)

Method Summary

Modifier and Type	Method	Description
protected final U	computeValue()
protected final Subscription	connect()	Implementation of this method should start observing inputs.
private void	selectedInvalidated()
private void	srcInvalidated()
private void	startObservingSelected()
private void	stopObservingSelected()

Methods inherited from class ValBase

getValue, invalidate, newObserver, observeInputs

Methods inherited from class ObservableBase

addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, notifyObservers, notifyObservers, observe, removeObserver, toString

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface Observable

addObserver, observe, removeObserver

Methods inherited from interface ProperObservable

defaultEquals, defaultHashCode, defaultToString, notifyObservers

Methods inherited from interface ProperVal

defaultNotificationAccumulator

Methods inherited from interface Val

addInvalidationObserver, addListener, addListener, animate, animate, asList, asVar, changes, conditionOn, conditionOnShowing, filter, flatMap, getOpt, getOrElse, getOrSupply, getOrThrow, ifPresent, invalidations, isEmpty, isPresent, map, mapDynamic, observeChanges, observeInvalidations, orElse, orElseConst, pin, removeInvalidationObserver, removeListener, removeListener, selectVar, selectVar, suspendable, values

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