Interface ObservableStatic

Index

Properties

Methods

Properties

public fromCallback: { <TResult>(func: (callback: (result: TResult) => any) => any, scheduler?: Rx.IScheduler, context?: any): () => Rx.Observable<TResult>; <T1, TResult>(func: (arg1: T1, callback: (result: TResult) => any) => any, scheduler?: Rx.IScheduler, context?: any): (arg1: T1) => Rx.Observable<TResult>; <T1, T2, TResult>(func: (arg1: T1, arg2: T2, callback: (result: TResult) => any) => any, scheduler?: Rx.IScheduler, context?: any): (arg1: T1, arg2: T2) => Rx.Observable<TResult>; <T1, T2, T3, TResult>(func: (arg1: T1, arg2: T2, arg3: T3, callback: (result: TResult) => any) => any, scheduler?: Rx.IScheduler, context?: any): (arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TResult>; <TCallbackResult, TResult>(func: (callback: Function) => any, scheduler: Rx.IScheduler, context: any, selector: (args: TCallbackResult[]) => TResult): () => Rx.Observable<TResult>; <T1, TCallbackResult, TResult>(func: (arg1: T1, callback: Function) => any, scheduler: Rx.IScheduler, context: any, selector: (args: TCallbackResult[]) => TResult): (arg1: T1) => Rx.Observable<TResult>; <T1, T2, TCallbackResult, TResult>(func: (arg1: T1, arg2: T2, callback: Function) => any, scheduler: Rx.IScheduler, context: any, selector: (args: TCallbackResult[]) => TResult): (arg1: T1, arg2: T2) => Rx.Observable<TResult>; <T1, T2, T3, TCallbackResult, TResult>(func: (arg1: T1, arg2: T2, arg3: T3, callback: Function) => any, scheduler: Rx.IScheduler, context: any, selector: (args: TCallbackResult[]) => TResult): (arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TResult>; <TResult>(func: (callback: Function) => any, scheduler?: Rx.IScheduler, context?: any): () => Rx.Observable<TResult>; <T1, TResult>(func: (arg1: T1, callback: Function) => any, scheduler?: Rx.IScheduler, context?: any): (arg1: T1) => Rx.Observable<TResult>; <T1, T2, TResult>(func: (arg1: T1, arg2: T2, callback: Function) => any, scheduler?: Rx.IScheduler, context?: any): (arg1: T1, arg2: T2) => Rx.Observable<TResult>; <T1, T2, T3, TResult>(func: (arg1: T1, arg2: T2, arg3: T3, callback: Function) => any, scheduler?: Rx.IScheduler, context?: any): (arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TResult>; <TCallbackResult, TResult>(func: Function, scheduler: Rx.IScheduler, context: any, selector: (args: TCallbackResult[]) => TResult): (...args: any[]) => Rx.Observable<TResult>; <TResult>(func: Function, scheduler?: Rx.IScheduler, context?: any): (...args: any[]) => Rx.Observable<TResult>; }

(): (arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TResult>

Returns

(arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TResult>

(): () => Rx.Observable<TResult>

Returns

() => Rx.Observable<TResult>

(): (arg1: T1, arg2: T2) => Rx.Observable<TResult>

Returns

(arg1: T1, arg2: T2) => Rx.Observable<TResult>

(): (arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TResult>

Returns

(arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TResult>

(): () => Rx.Observable<TResult>

Returns

() => Rx.Observable<TResult>

(): (arg1: T1) => Rx.Observable<TResult>

Returns

(arg1: T1) => Rx.Observable<TResult>

(): (arg1: T1, arg2: T2) => Rx.Observable<TResult>

Returns

(arg1: T1, arg2: T2) => Rx.Observable<TResult>

(): (arg1: T1) => Rx.Observable<TResult>

Returns

(arg1: T1) => Rx.Observable<TResult>

(): () => Rx.Observable<TResult>

Returns

() => Rx.Observable<TResult>

(): (arg1: T1) => Rx.Observable<TResult>

Returns

(arg1: T1) => Rx.Observable<TResult>

(): (arg1: T1, arg2: T2) => Rx.Observable<TResult>

Returns

(arg1: T1, arg2: T2) => Rx.Observable<TResult>

(): (arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TResult>

Returns

(arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TResult>

(): (...args: any[]) => Rx.Observable<TResult>

Returns

(...args: any[]) => Rx.Observable<TResult>

(): (...args: any[]) => Rx.Observable<TResult>

Returns

(...args: any[]) => Rx.Observable<TResult>

public fromNodeCallback: { <T>(func: (callback: (err: any, result: T) => any) => any, scheduler?: Rx.IScheduler, context?: any): () => Rx.Observable<T>; <T1, T>(func: (arg1: T1, callback: (err: any, result: T) => any) => any, scheduler?: Rx.IScheduler, context?: any): (arg1: T1) => Rx.Observable<T>; <T1, T2, T>(func: (arg1: T1, arg2: T2, callback: (err: any, result: T) => any) => any, scheduler?: Rx.IScheduler, context?: any): (arg1: T1, arg2: T2) => Rx.Observable<T>; <T1, T2, T3, T>(func: (arg1: T1, arg2: T2, arg3: T3, callback: (err: any, result: T) => any) => any, scheduler?: Rx.IScheduler, context?: any): (arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<T>; <TC, TR>(func: (callback: Function) => any, scheduler: Rx.IScheduler, context: any, selector: (results: TC[]) => TR): () => Rx.Observable<TR>; <T1, TC, TR>(func: (arg1: T1, callback: Function) => any, scheduler: Rx.IScheduler, context: any, selector: (results: TC[]) => TR): (arg1: T1) => Rx.Observable<TR>; <T1, T2, TC, TR>(func: (arg1: T1, arg2: T2, callback: Function) => any, scheduler: Rx.IScheduler, context: any, selector: (results: TC[]) => TR): (arg1: T1, arg2: T2) => Rx.Observable<TR>; <T1, T2, T3, TC, TR>(func: (arg1: T1, arg2: T2, arg3: T3, callback: Function) => any, scheduler: Rx.IScheduler, context: any, selector: (results: TC[]) => TR): (arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TR>; <TR>(func: (callback: Function) => any, scheduler?: Rx.IScheduler, context?: any): () => Rx.Observable<TR>; <T1, TR>(func: (arg1: T1, callback: Function) => any, scheduler?: Rx.IScheduler, context?: any): (arg1: T1) => Rx.Observable<TR>; <T1, T2, TR>(func: (arg1: T1, arg2: T2, callback: Function) => any, scheduler?: Rx.IScheduler, context?: any): (arg1: T1, arg2: T2) => Rx.Observable<TR>; <T1, T2, T3, TR>(func: (arg1: T1, arg2: T2, arg3: T3, callback: Function) => any, scheduler?: Rx.IScheduler, context?: any): (arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TR>; <TC, T>(func: Function, scheduler: Rx.IScheduler, context: any, selector: (results: TC[]) => T): (...args: any[]) => Rx.Observable<T>; <T>(func: Function, scheduler?: Rx.IScheduler, context?: any): (...args: any[]) => Rx.Observable<T>; }

(): (arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TR>

Returns

(arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TR>

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

Returns

() => Rx.Observable<T>

(): (arg1: T1, arg2: T2) => Rx.Observable<T>

Returns

(arg1: T1, arg2: T2) => Rx.Observable<T>

(): (arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<T>

Returns

(arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<T>

(): () => Rx.Observable<TR>

Returns

() => Rx.Observable<TR>

(): (arg1: T1) => Rx.Observable<TR>

Returns

(arg1: T1) => Rx.Observable<TR>

(): (arg1: T1, arg2: T2) => Rx.Observable<TR>

Returns

(arg1: T1, arg2: T2) => Rx.Observable<TR>

(): (arg1: T1) => Rx.Observable<T>

Returns

(arg1: T1) => Rx.Observable<T>

(): () => Rx.Observable<TR>

Returns

() => Rx.Observable<TR>

(): (arg1: T1) => Rx.Observable<TR>

Returns

(arg1: T1) => Rx.Observable<TR>

(): (arg1: T1, arg2: T2) => Rx.Observable<TR>

Returns

(arg1: T1, arg2: T2) => Rx.Observable<TR>

(): (arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TR>

Returns

(arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TR>

(): (...args: any[]) => Rx.Observable<T>

Returns

(...args: any[]) => Rx.Observable<T>

(): (...args: any[]) => Rx.Observable<T>

Returns

(...args: any[]) => Rx.Observable<T>

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 fromEvent(element: NodeList, eventName: string, selector?: (arguments: any[]) => T): Observable

Parameters

  • element: NodeList
  • eventName: string
  • selector?: (arguments: any[]) => T optional

Returns

Observable

public fromEvent(element: Node, eventName: string, selector?: (arguments: any[]) => T): Observable

Parameters

  • element: Node
  • eventName: string
  • selector?: (arguments: any[]) => T optional

Returns

Observable

public fromEventPattern(addHandler: (handler: Function) => void, removeHandler: (handler: Function) => void, selector?: (arguments: any[]) => T): Observable

Parameters

  • addHandler: (handler: Function) => void
  • removeHandler: (handler: Function) => void
  • selector?: (arguments: any[]) => T 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 start(func: () => T, scheduler?: IScheduler, context?: any): Observable

Parameters

  • func: () => T
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

Observable

public startAsync(functionAsync: () => Rx.IPromise<T>): Observable

Invokes the asynchronous function, surfacing the result through an observable sequence.

Parameters

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

    Asynchronous function which returns a Promise to run.

Returns

Observable

An observable sequence exposing the function's result value, or an exception.

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 toAsync(func: () => TResult, scheduler?: IScheduler, context?: any): () => Rx.Observable<TResult>

Parameters

  • func: () => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

() => Rx.Observable<TResult>

public toAsync(func: (arg1: T1) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1) => Rx.Observable<TResult>

public toAsync(func: (arg1?: T1) => TResult, scheduler?: IScheduler, context?: any): (arg1?: T1) => Rx.Observable<TResult>

Parameters

  • func: (arg1?: T1) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1?: T1) => Rx.Observable<TResult>

public toAsync(func: (...args: T1[]) => TResult, scheduler?: IScheduler, context?: any): (...args: T1[]) => Rx.Observable<TResult>

Parameters

  • func: (...args: T1[]) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(...args: T1[]) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2: T2) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2: T2) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2: T2) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2: T2) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2?: T2) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2?: T2) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2?: T2) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2?: T2) => Rx.Observable<TResult>

public toAsync(func: (arg1?: T1, arg2?: T2) => TResult, scheduler?: IScheduler, context?: any): (arg1?: T1, arg2?: T2) => Rx.Observable<TResult>

Parameters

  • func: (arg1?: T1, arg2?: T2) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1?: T1, arg2?: T2) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, ...args: T2[]) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, ...args: T2[]) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, ...args: T2[]) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, ...args: T2[]) => Rx.Observable<TResult>

public toAsync(func: (arg1?: T1, ...args: T2[]) => TResult, scheduler?: IScheduler, context?: any): (arg1?: T1, ...args: T2[]) => Rx.Observable<TResult>

Parameters

  • func: (arg1?: T1, ...args: T2[]) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1?: T1, ...args: T2[]) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2: T2, arg3: T3) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2: T2, arg3: T3) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2: T2, arg3: T3) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2: T2, arg3?: T3) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2: T2, arg3?: T3) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2: T2, arg3?: T3) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2: T2, arg3?: T3) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2?: T2, arg3?: T3) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2?: T2, arg3?: T3) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2?: T2, arg3?: T3) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2?: T2, arg3?: T3) => Rx.Observable<TResult>

public toAsync(func: (arg1?: T1, arg2?: T2, arg3?: T3) => TResult, scheduler?: IScheduler, context?: any): (arg1?: T1, arg2?: T2, arg3?: T3) => Rx.Observable<TResult>

Parameters

  • func: (arg1?: T1, arg2?: T2, arg3?: T3) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1?: T1, arg2?: T2, arg3?: T3) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2: T2, ...args: T3[]) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2: T2, ...args: T3[]) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2: T2, ...args: T3[]) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2: T2, ...args: T3[]) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2?: T2, ...args: T3[]) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2?: T2, ...args: T3[]) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2?: T2, ...args: T3[]) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2?: T2, ...args: T3[]) => Rx.Observable<TResult>

public toAsync(func: (arg1?: T1, arg2?: T2, ...args: T3[]) => TResult, scheduler?: IScheduler, context?: any): (arg1?: T1, arg2?: T2, ...args: T3[]) => Rx.Observable<TResult>

Parameters

  • func: (arg1?: T1, arg2?: T2, ...args: T3[]) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1?: T1, arg2?: T2, ...args: T3[]) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2: T2, arg3: T3, arg4: T4) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2: T2, arg3: T3, arg4: T4) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2: T2, arg3: T3, arg4: T4) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2: T2, arg3: T3, arg4: T4) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2: T2, arg3: T3, arg4?: T4) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2: T2, arg3: T3, arg4?: T4) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2: T2, arg3: T3, arg4?: T4) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2: T2, arg3: T3, arg4?: T4) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2: T2, arg3?: T3, arg4?: T4) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2: T2, arg3?: T3, arg4?: T4) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2: T2, arg3?: T3, arg4?: T4) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2: T2, arg3?: T3, arg4?: T4) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2?: T2, arg3?: T3, arg4?: T4) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2?: T2, arg3?: T3, arg4?: T4) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2?: T2, arg3?: T3, arg4?: T4) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2?: T2, arg3?: T3, arg4?: T4) => Rx.Observable<TResult>

public toAsync(func: (arg1?: T1, arg2?: T2, arg3?: T3, arg4?: T4) => TResult, scheduler?: IScheduler, context?: any): (arg1?: T1, arg2?: T2, arg3?: T3, arg4?: T4) => Rx.Observable<TResult>

Parameters

  • func: (arg1?: T1, arg2?: T2, arg3?: T3, arg4?: T4) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1?: T1, arg2?: T2, arg3?: T3, arg4?: T4) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2: T2, arg3: T3, ...args: T4[]) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2: T2, arg3: T3, ...args: T4[]) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2: T2, arg3: T3, ...args: T4[]) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2: T2, arg3: T3, ...args: T4[]) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2: T2, arg3?: T3, ...args: T4[]) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2: T2, arg3?: T3, ...args: T4[]) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2: T2, arg3?: T3, ...args: T4[]) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2: T2, arg3?: T3, ...args: T4[]) => Rx.Observable<TResult>

public toAsync(func: (arg1: T1, arg2?: T2, arg3?: T3, ...args: T4[]) => TResult, scheduler?: IScheduler, context?: any): (arg1: T1, arg2?: T2, arg3?: T3, ...args: T4[]) => Rx.Observable<TResult>

Parameters

  • func: (arg1: T1, arg2?: T2, arg3?: T3, ...args: T4[]) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1: T1, arg2?: T2, arg3?: T3, ...args: T4[]) => Rx.Observable<TResult>

public toAsync(func: (arg1?: T1, arg2?: T2, arg3?: T3, ...args: T4[]) => TResult, scheduler?: IScheduler, context?: any): (arg1?: T1, arg2?: T2, arg3?: T3, ...args: T4[]) => Rx.Observable<TResult>

Parameters

  • func: (arg1?: T1, arg2?: T2, arg3?: T3, ...args: T4[]) => TResult
  • scheduler?: IScheduler optional
  • context?: any optional

Returns

(arg1?: T1, arg2?: T2, arg3?: T3, ...args: T4[]) => Rx.Observable<TResult>

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

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