From b5c9860090ad5898d7e7a6d9473e3b97ff94ab97 Mon Sep 17 00:00:00 2001 From: Igor Oleinikov Date: Tue, 15 Jul 2014 08:51:27 -0700 Subject: [PATCH] Added `exclusive` operator. --- rx.js/rx-lite.d.ts | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/rx.js/rx-lite.d.ts b/rx.js/rx-lite.d.ts index 5c20fd39d..3e5fa2b78 100644 --- a/rx.js/rx-lite.d.ts +++ b/rx.js/rx-lite.d.ts @@ -352,6 +352,16 @@ declare module Rx { * @returns An ES6 compatible promise with the last value from the observable sequence. */ toPromise(promiseCtor?: { new (resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void): IPromise; }): IPromise; + + // Experimental Flattening + + /** + * Performs a exclusive waiting for the first to finish before subscribing to another observable. + * Observables that come in between subscriptions will be dropped on the floor. + * Can be applied on `Observable>` or `Observable>`. + * @returns A exclusive observable with only the results that happen when subscribed. + */ + exclusive(): Observable; } interface ObservableStatic {