Observable<T> class abstract

Observable is a sequence of data that can be emitted synchronously or asynchronously.

Technical speaking, Observable is an interface that has an observe method:

abstract class Observable<T> {
  Disposable observe(OnData<T> onData);
}

Example:

final observable = Observable<int>((onData) {
  onData(0);
  onData(1);
  onData(2);
  return Disposable.empty;
});

Above example create an Observable using inline observe method (onData) { ... }. It will emit data synchronously when observed:

print('before observe');

final observation = observable.observe((data) {
  print('onData: $data');
});

print('after observe');

Prints:

before observe
onData: 0
onData: 1
onData: 2
after observe

Implementers

Available Extensions

Constructors

Observable(Observe<T> inlineObserve): Use Observable(...) to create an Observable with an inline observe method (onData) { ... }.
const

factory

Properties

hashCode → int: The hash code for this object.
no setterinherited
runtimeType → Type: A representation of the runtime type of the object.
no setterinherited

Methods

noSuchMethod(Invocation invocation) → dynamic: Invoked when a nonexistent method or property is accessed.
inherited
observe(OnData<T> onData) → Disposable: Use observable.observe to start observe an observable, use returned observation to stop observe.
toString() → String: A string representation of this object.
inherited

Operators

operator ==(Object other) → bool: The equality operator.
inherited

Static Methods

combine<T, R>({required List<Observable<T>> sources, required R combiner(List<T> items)}) → Observable<R>: Combine multiple Observable into one Observable.
combine2<T1, T2, R>({required Observable<T1> source1, required Observable<T2> source2, required R combiner(T1, T2)}) → Observable<R>: Combine two Observable into one Observable.
combine3<T1, T2, T3, R>({required Observable<T1> source1, required Observable<T2> source2, required Observable<T3> source3, required R combiner(T1, T2, T3)}) → Observable<R>: Combine three Observable into one Observable.
combine4<T1, T2, T3, T4, R>({required Observable<T1> source1, required Observable<T2> source2, required Observable<T3> source3, required Observable<T4> source4, required R combiner(T1, T2, T3, T4)}) → Observable<R>: Combine four Observable into one Observable.
combine5<T1, T2, T3, T4, T5, R>({required Observable<T1> source1, required Observable<T2> source2, required Observable<T3> source3, required Observable<T4> source4, required Observable<T5> source5, required R combiner(T1, T2, T3, T4, T5)}) → Observable<R>: Combine five Observable into one Observable.
combine6<T1, T2, T3, T4, T5, T6, R>({required Observable<T1> source1, required Observable<T2> source2, required Observable<T3> source3, required Observable<T4> source4, required Observable<T5> source5, required Observable<T6> source6, required R combiner(T1, T2, T3, T4, T5, T6)}) → Observable<R>: Combine six Observable into one Observable.
combine7<T1, T2, T3, T4, T5, T6, T7, R>({required Observable<T1> source1, required Observable<T2> source2, required Observable<T3> source3, required Observable<T4> source4, required Observable<T5> source5, required Observable<T6> source6, required Observable<T7> source7, required R combiner(T1, T2, T3, T4, T5, T6, T7)}) → Observable<R>: Combine seven Observable into one Observable.
combine8<T1, T2, T3, T4, T5, T6, T7, T8, R>({required Observable<T1> source1, required Observable<T2> source2, required Observable<T3> source3, required Observable<T4> source4, required Observable<T5> source5, required Observable<T6> source6, required Observable<T7> source7, required Observable<T8> source8, required R combiner(T1, T2, T3, T4, T5, T6, T7, T8)}) → Observable<R>: Combine eight Observable into one Observable.
combine9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R>({required Observable<T1> source1, required Observable<T2> source2, required Observable<T3> source3, required Observable<T4> source4, required Observable<T5> source5, required Observable<T6> source6, required Observable<T7> source7, required Observable<T8> source8, required Observable<T9> source9, required R combiner(T1, T2, T3, T4, T5, T6, T7, T8, T9)}) → Observable<R>: Combine nine Observable into one Observable.