Interface ObservableStatic

Index

Methods

Methods

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

public amb(sources: Observable[]): Observable

Parameters

Returns

Observable

public amb(sources: IPromise[]): Observable

Parameters

Returns

Observable

public catch(sources: Observable[]): Observable

Parameters

Returns

Observable

public catch(sources: IPromise[]): Observable

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

public catchException(sources: Observable[]): Observable

Parameters

Returns

Observable

public catchException(sources: IPromise[]): Observable

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

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

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

Returns

Observable

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

Parameters

Returns

Observable

public concat(sources: Observable[]): Observable

Parameters

Returns

Observable

public concat(sources: IPromise[]): Observable

Parameters

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

Returns

Observable

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

Parameters

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

Returns

Observable

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

Parameters

Returns

Observable

public merge(sources: Observable[]): Observable

Parameters

Returns

Observable

public merge(sources: IPromise[]): Observable

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

public never(): Observable

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

public onErrorResumeNext(sources: Observable[]): Observable

Parameters

Returns

Observable

public onErrorResumeNext(sources: IPromise[]): Observable

Parameters

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

Returns

Observable

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

Parameters

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

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

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 when(plan: Plan): Observable

Parameters

Returns

Observable

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

Parameters

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

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

Returns

Observable

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

Parameters

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

Returns

Observable

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

Parameters

Returns

Observable

public zipArray(sources: Observable[]): Observable

Parameters

Returns

Observable