ObservableFuture<T> class

Implemented types


ObservableFuture(Future<T> future, { ReactiveContext context })
Create a new observable future that tracks the state of the provided future.
ObservableFuture.error(dynamic error, { ReactiveContext context })
Create a new future that is completed with an error. [...]
ObservableFuture.value(T value, { ReactiveContext context })
Create a new future that is completed with a value. [...]


error → dynamic
Error value if this completed with an error [...]
result → dynamic
Error or value of this. [...]
status FutureStatus
Observable status of this.
value → T
Value if this completed with a value. [...]
read-only, override
hashCode → int
The hash code for this object.
read-only, inherited
runtimeType → Type
A representation of the runtime type of the object.
read-only, inherited


asStream() ObservableStream<T>
Creates a Stream containing the result of this future. [...]
catchError(Function onError, { bool test(Object error) }) ObservableFuture<T>
Handles errors emitted by this Future. [...]
match<R>({R fulfilled(T), R rejected(dynamic), R pending() }) → R
Maps the current state of this. [...]
replace(Future<T> nextFuture) ObservableFuture<T>
Returns a new future that starts with the status and result of this. [...]
then<R>(FutureOr<R> onValue(T value), { Function onError }) ObservableFuture<R>
Register callbacks to be called when this future completes. [...]
timeout(Duration timeLimit, { FutureOr<T> onTimeout() }) ObservableFuture<T>
Time-out the future computation after timeLimit has passed. [...]
whenComplete(FutureOr action()) ObservableFuture<T>
Registers a function to be called when this future completes. [...]
noSuchMethod(Invocation invocation) → dynamic
Invoked when a non-existent method or property is accessed.
toString() → String
Returns a string representation of this object.


operator ==(dynamic other) → bool
The equality operator.