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 {