public class ImmutableObservableValue<T> extends java.lang.Object implements ObservableValue<T>
ObservableValue.Change<T>| Constructor and Description |
|---|
ImmutableObservableValue(T message) |
ImmutableObservableValue(java.lang.Throwable failure) |
| Modifier and Type | Method and Description |
|---|---|
Observable<ObservableValue.Change<T>> |
changes() |
T |
get()
Immediately resolve the current value if one exists, otherwise throw a
MissingValueException with a cause representing the current failure
state. |
Disposable |
observe(Observer<? super T> observer)
Observers added will receive messages from this Observable.
|
ObservableValue<T> |
toValue() |
ObservableValue<T> |
toValue(T initial) |
ObservableValue<T> |
toValue(java.lang.Throwable initialProblem) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetProblem, isEqual, isMatching, isValid, tryGet, tryGetProblemaggregateBackpressure, aggregateBackpressure, collect, collectBackpressure, compose, concat, concat, concatMap, dropWhile, empty, executeOn, failingValue, filter, flatMap, getNext, map, materialize, merge, merge, mergeMap, observe, of, of, of, reduce, reduceBackpressure, reduceBackpressure, reduceBackpressure, repeating, requestNext, requestUnbounded, retrying, softReference, softReference, synchronize, synchronize, takeWhile, then, thenAfter, toObservable, upcast, value, weakReference, weakReferencepublic ImmutableObservableValue(T message)
public ImmutableObservableValue(java.lang.Throwable failure)
public Disposable observe(Observer<? super T> observer)
Observableobserve in interface Observable<T>observer - an observer to addpublic ObservableValue<T> toValue()
toValue in interface Observable<T>public ObservableValue<T> toValue(T initial)
toValue in interface Observable<T>public ObservableValue<T> toValue(java.lang.Throwable initialProblem)
toValue in interface Observable<T>public T get()
ObservableValueMissingValueException with a cause representing the current failure
state.get in interface Observable<T>get in interface ObservableValue<T>public Observable<ObservableValue.Change<T>> changes()
changes in interface ObservableValue<T>