rx.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<T>({Scheduler scheduler}) Observable<T>
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) Observable<T>
Creates an Observable which concurrently emits all values from every source Observable.
never<T>() Observable<T>
An Observable that emits no items and never completes.
throwError<T>(Object error, {StackTrace stackTrace, Scheduler scheduler}) Observable<T>
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.