From 5094254e616a4ddd9825fdf05820cf847c3c257e Mon Sep 17 00:00:00 2001 From: Igor Oleinikov Date: Tue, 1 Apr 2014 13:39:04 +0400 Subject: [PATCH] Added overloads of `defer` and `catch`/`catchException` with handle promises. --- rx.js/rx-lite.ts | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/rx.js/rx-lite.ts b/rx.js/rx-lite.ts index 201e7143f..c0a27c3c4 100644 --- a/rx.js/rx-lite.ts +++ b/rx.js/rx-lite.ts @@ -320,6 +320,7 @@ declare module Rx { create(subscribe: (observer: Observer) => IDisposable): Observable; createWithDisposable(subscribe: (observer: Observer) => IDisposable): Observable; defer(observableFactory: () => Observable): Observable; + defer(observableFactory: () => IPromise): Observable; empty(scheduler?: IScheduler): Observable; fromArray(array: T[], scheduler?: IScheduler): Observable; fromArray(array: { length: number;[index: number]: T; }, scheduler?: IScheduler): Observable; @@ -360,9 +361,13 @@ declare module Rx { throwException(exception: any, scheduler?: IScheduler): Observable; // alias for throw catch(sources: Observable[]): Observable; + catch(sources: IPromise[]): Observable; catchException(sources: Observable[]): Observable; // alias for catch + catchException(sources: IPromise[]): Observable; // alias for catch catch(...sources: Observable[]): Observable; + catch(...sources: IPromise[]): Observable; catchException(...sources: Observable[]): Observable; // alias for catch + catchException(...sources: IPromise[]): Observable; // alias for catch concat(...sources: Observable[]): Observable; concat(...sources: IPromise[]): Observable; concat(sources: Observable[]): Observable;