constructors
library
Functions
-
combineLatest<T>(Iterable<Observable<T>> iterable, {Scheduler? scheduler})
→ Observable<List<T>>
-
Combines a list of Observable to an Observable whose values are
calculated from the latest values of each of its inputs.
-
concat<T>(Iterable<Observable<T>> observables, {Scheduler? scheduler})
→ Observable<T>
-
Subscribe to the list of Observable in order, and when the previous one
complete then subscribe to the next one.
-
create<T>(Callback1<Subscriber<T>> callback)
→ Observable<T>
-
Creates an Observable that uses the provided
callback to emit elements
to the provided Observer on each subscribe.
-
defer<T>(Map0<Observable<T>> callback)
→ Observable<T>
-
Creates an Observable that uses the provided
callback to create a new
Observable on each subscribe.
-
empty({Scheduler? scheduler})
→ Observable<Never>
-
An Observable that emits no items and immediately completes.
-
forkJoin<T>(List<Observable<T>> sources)
→ Observable<List<T>>
-
Waits for all passed Observable to complete and then it will emit an
list with last values from corresponding observables.
-
iff<T>(Predicate0 condition, [Observable<T>? trueBranch, Observable<T>? falseBranch])
→ Observable<T>
-
Decides at subscription time which Observable will actually be
subscribed to.
-
just<T>(T value, {Scheduler? scheduler})
→ Observable<T>
-
An Observable with a single element.
-
merge<T>(Iterable<Observable<T>> observables, {int concurrent = maxInteger})
→ Observable<T>
-
Creates an Observable which concurrently emits all values from every
source Observable.
-
never()
→ Observable<Never>
-
An Observable that emits no items and never completes.
-
race<T>(Iterable<Observable<T>> sources)
→ Observable<T>
-
Creates an Observable that mirrors the first source to emit an item.
-
throwError(Object error, {StackTrace? stackTrace, Scheduler? scheduler})
→ Observable<Never>
-
An Observable that emits no items and immediately throws an error.
-
timer({Duration delay = Duration.zero, Duration? period, Scheduler? scheduler})
→ Observable<int>
-
An Observable that starts emitting after
delay and that emits an ever
increasing numbers after each period thereafter.
-
zip<T>(Iterable<Observable<T>> iterable, {Scheduler? scheduler})
→ Observable<List<T>>
-
Combines a list of Observable to an Observable whose values are
calculated from the next value of each of its inputs.
