Interface ObservableStatic

public amb(sources?: Observable[]): Observable

Parameters

• sources?: Observable[] optional

Returns

Observable

public amb(sources?: IPromise[]): Observable

Parameters

• sources?: IPromise[] optional

Returns

Observable

public amb(sources: Observable[]): Observable

Parameters

• sources: Observable[]

Returns

Observable

public amb(sources: IPromise[]): Observable

Parameters

• sources: IPromise[]

Returns

Observable

public catch(sources: Observable[]): Observable

Parameters

• sources: Observable[]

Returns

Observable

public catch(sources: IPromise[]): Observable

Parameters

• sources: IPromise[]

Returns

Observable

public catch(sources?: Observable[]): Observable

Parameters

• sources?: Observable[] optional

Returns

Observable

public catch(sources?: IPromise[]): Observable

Parameters

• sources?: IPromise[] optional

Returns

Observable

public catchException(sources: Observable[]): Observable

Parameters

• sources: Observable[]

Returns

Observable

public catchException(sources: IPromise[]): Observable

Parameters

• sources: IPromise[]

Returns

Observable

public catchException(sources?: Observable[]): Observable

Parameters

• sources?: Observable[] optional

Returns

Observable

public catchException(sources?: IPromise[]): Observable

Parameters

• sources?: IPromise[] optional

Returns

Observable

public combineLatest(first: Observable, second: Observable, resultSelector: (v1: T, v2: T2) => TResult): Observable

Parameters

• first: Observable

• second: Observable

• resultSelector: (v1: T, v2: T2) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: Observable, resultSelector: (v1: T, v2: T2) => TResult): Observable

Parameters

• first: IPromise

• second: Observable

• resultSelector: (v1: T, v2: T2) => TResult

Returns

Observable

public combineLatest(first: Observable, second: IPromise, resultSelector: (v1: T, v2: T2) => TResult): Observable

Parameters

• first: Observable

• second: IPromise

• resultSelector: (v1: T, v2: T2) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: IPromise, resultSelector: (v1: T, v2: T2) => TResult): Observable

Parameters

• first: IPromise

• second: IPromise

• resultSelector: (v1: T, v2: T2) => TResult

Returns

Observable

public combineLatest(first: Observable, second: Observable, third: Observable, resultSelector: (v1: T, v2: T2, v3: T3) => TResult): Observable

Parameters

• first: Observable

• second: Observable

• third: Observable

• resultSelector: (v1: T, v2: T2, v3: T3) => TResult

Returns

Observable

public combineLatest(first: Observable, second: Observable, third: IPromise, resultSelector: (v1: T, v2: T2, v3: T3) => TResult): Observable

Parameters

• first: Observable

• second: Observable

• third: IPromise

• resultSelector: (v1: T, v2: T2, v3: T3) => TResult

Returns

Observable

public combineLatest(first: Observable, second: IPromise, third: Observable, resultSelector: (v1: T, v2: T2, v3: T3) => TResult): Observable

Parameters

• first: Observable

• second: IPromise

• third: Observable

• resultSelector: (v1: T, v2: T2, v3: T3) => TResult

Returns

Observable

public combineLatest(first: Observable, second: IPromise, third: IPromise, resultSelector: (v1: T, v2: T2, v3: T3) => TResult): Observable

Parameters

• first: Observable

• second: IPromise

• third: IPromise

• resultSelector: (v1: T, v2: T2, v3: T3) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: Observable, third: Observable, resultSelector: (v1: T, v2: T2, v3: T3) => TResult): Observable

Parameters

• first: IPromise

• second: Observable

• third: Observable

• resultSelector: (v1: T, v2: T2, v3: T3) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: Observable, third: IPromise, resultSelector: (v1: T, v2: T2, v3: T3) => TResult): Observable

Parameters

• first: IPromise

• second: Observable

• third: IPromise

• resultSelector: (v1: T, v2: T2, v3: T3) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: IPromise, third: Observable, resultSelector: (v1: T, v2: T2, v3: T3) => TResult): Observable

Parameters

• first: IPromise

• second: IPromise

• third: Observable

• resultSelector: (v1: T, v2: T2, v3: T3) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: IPromise, third: IPromise, resultSelector: (v1: T, v2: T2, v3: T3) => TResult): Observable

Parameters

• first: IPromise

• second: IPromise

• third: IPromise

• resultSelector: (v1: T, v2: T2, v3: T3) => TResult

Returns

Observable

public combineLatest(first: Observable, second: Observable, third: Observable, fourth: Observable, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: Observable

• second: Observable

• third: Observable

• fourth: Observable

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: Observable, second: Observable, third: Observable, fourth: IPromise, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: Observable

• second: Observable

• third: Observable

• fourth: IPromise

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: Observable, second: Observable, third: IPromise, fourth: Observable, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: Observable

• second: Observable

• third: IPromise

• fourth: Observable

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: Observable, second: Observable, third: IPromise, fourth: IPromise, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: Observable

• second: Observable

• third: IPromise

• fourth: IPromise

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: Observable, second: IPromise, third: Observable, fourth: Observable, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: Observable

• second: IPromise

• third: Observable

• fourth: Observable

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: Observable, second: IPromise, third: Observable, fourth: IPromise, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: Observable

• second: IPromise

• third: Observable

• fourth: IPromise

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: Observable, second: IPromise, third: IPromise, fourth: Observable, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: Observable

• second: IPromise

• third: IPromise

• fourth: Observable

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: Observable, second: IPromise, third: IPromise, fourth: IPromise, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: Observable

• second: IPromise

• third: IPromise

• fourth: IPromise

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: Observable, third: Observable, fourth: Observable, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: IPromise

• second: Observable

• third: Observable

• fourth: Observable

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: Observable, third: Observable, fourth: IPromise, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: IPromise

• second: Observable

• third: Observable

• fourth: IPromise

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: Observable, third: IPromise, fourth: Observable, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: IPromise

• second: Observable

• third: IPromise

• fourth: Observable

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: Observable, third: IPromise, fourth: IPromise, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: IPromise

• second: Observable

• third: IPromise

• fourth: IPromise

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: IPromise, third: Observable, fourth: Observable, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: IPromise

• second: IPromise

• third: Observable

• fourth: Observable

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: IPromise, third: Observable, fourth: IPromise, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: IPromise

• second: IPromise

• third: Observable

• fourth: IPromise

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: IPromise, third: IPromise, fourth: Observable, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: IPromise

• second: IPromise

• third: IPromise

• fourth: Observable

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: IPromise, second: IPromise, third: IPromise, fourth: IPromise, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable

Parameters

• first: IPromise

• second: IPromise

• third: IPromise

• fourth: IPromise

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult

Returns

Observable

public combineLatest(first: Observable, second: Observable, third: Observable, fourth: Observable, fifth: Observable, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult): Observable

Parameters

• first: Observable

• second: Observable

• third: Observable

• fourth: Observable

• fifth: Observable

• resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult

Returns

Observable

public combineLatest(souces: Observable[], resultSelector: (...otherValues: TOther[]) => TResult): Observable

Parameters

• souces: Observable[]

• resultSelector: (...otherValues: TOther[]) => TResult

Returns

Observable

public combineLatest(souces: IPromise[], resultSelector: (...otherValues: TOther[]) => TResult): Observable

Parameters

• souces: IPromise[]

• resultSelector: (...otherValues: TOther[]) => TResult

Returns

Observable

public concat(sources?: Observable[]): Observable

Parameters

• sources?: Observable[] optional

Returns

Observable

public concat(sources?: IPromise[]): Observable

Parameters

• sources?: IPromise[] optional

Returns

Observable

public concat(sources: Observable[]): Observable

Parameters

• sources: Observable[]

Returns

Observable

public concat(sources: IPromise[]): Observable

Parameters

• sources: IPromise[]

Returns

Observable

public create(subscribe: (observer: Rx.Observer<T>) => Rx.IDisposable): Observable

Parameters

• subscribe: (observer: Rx.Observer<T>) => Rx.IDisposable

Returns

Observable

public create(subscribe: (observer: Rx.Observer<T>) => () => void): Observable

Parameters

• subscribe: (observer: Rx.Observer<T>) => () => void

Returns

Observable

public create(subscribe: (observer: Rx.Observer<T>) => void): Observable

Parameters

• subscribe: (observer: Rx.Observer<T>) => void

Returns

Observable

public createWithDisposable(subscribe: (observer: Rx.Observer<T>) => Rx.IDisposable): Observable

Parameters

• subscribe: (observer: Rx.Observer<T>) => Rx.IDisposable

Returns

Observable

public defer(observableFactory: () => Rx.Observable<T>): Observable

Parameters

• observableFactory: () => Rx.Observable<T>

Returns

Observable

public defer(observableFactory: () => Rx.IPromise<T>): Observable

Parameters

• observableFactory: () => Rx.IPromise<T>

Returns

Observable

public empty(scheduler?: IScheduler): Observable

Parameters

• scheduler?: IScheduler optional

Returns

Observable

public fromArray(array: Array<T>, scheduler?: IScheduler): Observable

Parameters

• array: Array<T>

• scheduler?: IScheduler optional

Returns

Observable

public fromArray(array: { length: number; [index: number]: T; }, scheduler?: IScheduler): Observable

Parameters

• array: { length: number; [index: number]: T; }

• scheduler?: IScheduler optional

Returns

Observable

public fromItreable(generator: () => { next(): { done: boolean; value?: T; }; }, scheduler?: IScheduler): Observable

Converts an iterable into an Observable sequence

example

var res = Rx.Observable.fromIterable(new Map()); var res = Rx.Observable.fromIterable(function* () { yield 42; }); var res = Rx.Observable.fromIterable(new Set(), Rx.Scheduler.timeout);

Parameters

• generator: () => { next(): { done: boolean; value?: T; }; }

  Generator to convert from.

• scheduler?: IScheduler optional

Returns

Observable

The observable sequence whose elements are pulled from the given generator sequence.

public fromItreable(iterable: {}, scheduler?: IScheduler): Observable

Converts an iterable into an Observable sequence

example

var res = Rx.Observable.fromIterable(new Map()); var res = Rx.Observable.fromIterable(new Set(), Rx.Scheduler.timeout);

Parameters

• iterable: {}

  Iterable to convert from.

• scheduler?: IScheduler optional

Returns

Observable

The observable sequence whose elements are pulled from the given generator sequence.

public fromPromise(promise: IPromise): Observable

Converts a Promise to an Observable sequence

Parameters

• promise: IPromise

  An ES6 Compliant promise.

Returns

Observable

An Observable sequence which wraps the existing promise success and failure.

public generate(initialState: TState, condition: (state: TState) => boolean, iterate: (state: TState) => TState, resultSelector: (state: TState) => TResult, scheduler?: IScheduler): Observable

Parameters

• initialState: TState

• condition: (state: TState) => boolean

• iterate: (state: TState) => TState

• resultSelector: (state: TState) => TResult

• scheduler?: IScheduler optional

Returns

Observable

public merge(sources?: Observable[]): Observable

Parameters

• sources?: Observable[] optional

Returns

Observable

public merge(sources?: IPromise[]): Observable

Parameters

• sources?: IPromise[] optional

Returns

Observable

public merge(sources: Observable[]): Observable

Parameters

• sources: Observable[]

Returns

Observable

public merge(sources: IPromise[]): Observable

Parameters

• sources: IPromise[]

Returns

Observable

public merge(scheduler: IScheduler, sources?: Observable[]): Observable

Parameters

• scheduler: IScheduler

• sources?: Observable[] optional

Returns

Observable

public merge(scheduler: IScheduler, sources?: IPromise[]): Observable

Parameters

• scheduler: IScheduler

• sources?: IPromise[] optional

Returns

Observable

public merge(scheduler: IScheduler, sources: Observable[]): Observable

Parameters

• scheduler: IScheduler

• sources: Observable[]

Returns

Observable

public merge(scheduler: IScheduler, sources: IPromise[]): Observable

Parameters

• scheduler: IScheduler

• sources: IPromise[]

Returns

Observable

public never(): Observable

Returns

Observable

public onErrorResumeNext(sources?: Observable[]): Observable

Parameters

• sources?: Observable[] optional

Returns

Observable

public onErrorResumeNext(sources?: IPromise[]): Observable

Parameters

• sources?: IPromise[] optional

Returns

Observable

public onErrorResumeNext(sources: Observable[]): Observable

Parameters

• sources: Observable[]

Returns

Observable

public onErrorResumeNext(sources: IPromise[]): Observable

Parameters

• sources: IPromise[]

Returns

Observable

public range(start: number, count: number, scheduler?: IScheduler): Observable

Parameters

• start: number

• count: number

• scheduler?: IScheduler optional

Returns

Observable

public repeat(value: T, repeatCount?: number, scheduler?: IScheduler): Observable

Parameters

• value: T

• repeatCount?: number optional

• scheduler?: IScheduler optional

Returns

Observable

public return(value: T, scheduler?: IScheduler): Observable

Parameters

• value: T

• scheduler?: IScheduler optional

Returns

Observable

public returnValue(value: T, scheduler?: IScheduler): Observable

Parameters

• value: T

• scheduler?: IScheduler optional

Returns

Observable

public throw(exception: Error, scheduler?: IScheduler): Observable

Parameters

• exception: Error

• scheduler?: IScheduler optional

Returns

Observable

public throw(exception: any, scheduler?: IScheduler): Observable

Parameters

• exception: any

• scheduler?: IScheduler optional

Returns

Observable

public throwException(exception: Error, scheduler?: IScheduler): Observable

Parameters

• exception: Error

• scheduler?: IScheduler optional

Returns

Observable

public throwException(exception: any, scheduler?: IScheduler): Observable

Parameters

• exception: any

• scheduler?: IScheduler optional

Returns

Observable

public using(resourceFactory: () => TResource, observableFactory: (resource: TResource) => Rx.Observable<TSource>): Observable

Parameters

• resourceFactory: () => TResource

• observableFactory: (resource: TResource) => Rx.Observable<TSource>

Returns

Observable

public zip(first: Observable, sources: Observable[], resultSelector: (item1: T1, ...right: T2[]) => TResult): Observable

Parameters

• first: Observable

• sources: Observable[]

• resultSelector: (item1: T1, ...right: T2[]) => TResult

Returns

Observable

public zip(first: Observable, sources: IPromise[], resultSelector: (item1: T1, ...right: T2[]) => TResult): Observable

Parameters

• first: Observable

• sources: IPromise[]

• resultSelector: (item1: T1, ...right: T2[]) => TResult

Returns

Observable

public zip(source1: Observable, source2: Observable, resultSelector: (item1: T1, item2: T2) => TResult): Observable

Parameters

• source1: Observable

• source2: Observable

• resultSelector: (item1: T1, item2: T2) => TResult

Returns

Observable

public zip(source1: Observable, source2: IPromise, resultSelector: (item1: T1, item2: T2) => TResult): Observable

Parameters

• source1: Observable

• source2: IPromise

• resultSelector: (item1: T1, item2: T2) => TResult

Returns

Observable

public zip(source1: Observable, source2: Observable, source3: Observable, resultSelector: (item1: T1, item2: T2, item3: T3) => TResult): Observable

Parameters

• source1: Observable

• source2: Observable

• source3: Observable

• resultSelector: (item1: T1, item2: T2, item3: T3) => TResult

Returns

Observable

public zip(source1: Observable, source2: Observable, source3: IPromise, resultSelector: (item1: T1, item2: T2, item3: T3) => TResult): Observable

Parameters

• source1: Observable

• source2: Observable

• source3: IPromise

• resultSelector: (item1: T1, item2: T2, item3: T3) => TResult

Returns

Observable

public zip(source1: Observable, source2: IPromise, source3: Observable, resultSelector: (item1: T1, item2: T2, item3: T3) => TResult): Observable

Parameters

• source1: Observable

• source2: IPromise

• source3: Observable

• resultSelector: (item1: T1, item2: T2, item3: T3) => TResult

Returns

Observable

public zip(source1: Observable, source2: IPromise, source3: IPromise, resultSelector: (item1: T1, item2: T2, item3: T3) => TResult): Observable

Parameters

• source1: Observable

• source2: IPromise

• source3: IPromise

• resultSelector: (item1: T1, item2: T2, item3: T3) => TResult

Returns

Observable

public zip(source1: Observable, source2: Observable, source3: Observable, source4: Observable, resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult): Observable

Parameters

• source1: Observable

• source2: Observable

• source3: Observable

• source4: Observable

• resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult

Returns

Observable

public zip(source1: Observable, source2: Observable, source3: Observable, source4: IPromise, resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult): Observable

Parameters

• source1: Observable

• source2: Observable

• source3: Observable

• source4: IPromise

• resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult

Returns

Observable

public zip(source1: Observable, source2: Observable, source3: IPromise, source4: Observable, resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult): Observable

Parameters

• source1: Observable

• source2: Observable

• source3: IPromise

• source4: Observable

• resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult

Returns

Observable

public zip(source1: Observable, source2: Observable, source3: IPromise, source4: IPromise, resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult): Observable

Parameters

• source1: Observable

• source2: Observable

• source3: IPromise

• source4: IPromise

• resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult

Returns

Observable

public zip(source1: Observable, source2: IPromise, source3: Observable, source4: Observable, resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult): Observable

Parameters

• source1: Observable

• source2: IPromise

• source3: Observable

• source4: Observable

• resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult

Returns

Observable

public zip(source1: Observable, source2: IPromise, source3: Observable, source4: IPromise, resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult): Observable

Parameters

• source1: Observable

• source2: IPromise

• source3: Observable

• source4: IPromise

• resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult

Returns

Observable

public zip(source1: Observable, source2: IPromise, source3: IPromise, source4: Observable, resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult): Observable

Parameters

• source1: Observable

• source2: IPromise

• source3: IPromise

• source4: Observable

• resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult

Returns

Observable

public zip(source1: Observable, source2: IPromise, source3: IPromise, source4: IPromise, resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult): Observable

Parameters

• source1: Observable

• source2: IPromise

• source3: IPromise

• source4: IPromise

• resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult

Returns

Observable

public zip(source1: Observable, source2: Observable, source3: Observable, source4: Observable, source5: Observable, resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4, item5: T5) => TResult): Observable

Parameters

• source1: Observable

• source2: Observable

• source3: Observable

• source4: Observable

• source5: Observable

• resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4, item5: T5) => TResult

Returns

Observable

public zipArray(sources?: Observable[]): Observable

Parameters

• sources?: Observable[] optional

Returns

Observable

public zipArray(sources: Observable[]): Observable

Parameters

• sources: Observable[]

Returns

Observable