diff --git a/src/Observable.ts b/src/Observable.ts index b01fab065e..22b8d4080e 100644 --- a/src/Observable.ts +++ b/src/Observable.ts @@ -257,9 +257,7 @@ export class Observable implements CoreOperators { startWith: (x: T) => Observable; subscribeOn: (scheduler: Scheduler, delay?: number) => Observable; switch: () => Observable; - exhaust: () => Observable; switchMap: (project: ((x: T, ix: number) => Observable), projectResult?: (x: T, y: any, ix: number, iy: number) => R) => Observable; - exhaustMap: (project: (x: T, ix: number) => Observable, rSelector?: (x: T, y: R, ix: number, iy: number) => R2) => Observable; switchMapTo: (observable: Observable, projectResult?: (x: T, y: any, ix: number, iy: number) => R) => Observable; take: (count: number) => Observable; takeUntil: (notifier: Observable) => Observable; diff --git a/src/add/operator/exhaust.ts b/src/add/operator/exhaust.ts index ee84fb2de5..afc05bfab6 100644 --- a/src/add/operator/exhaust.ts +++ b/src/add/operator/exhaust.ts @@ -1,5 +1,7 @@ import {Observable} from '../../Observable'; import {exhaust} from '../../operator/exhaust'; -Observable.prototype.exhaust = exhaust; +import {KitchenSinkOperators} from '../../Rx.KitchenSink'; +const observableProto = (>Observable.prototype); +observableProto.exhaust = exhaust; export var _void: void; \ No newline at end of file diff --git a/src/add/operator/exhaustMap.ts b/src/add/operator/exhaustMap.ts index 420646fe33..f57a297892 100644 --- a/src/add/operator/exhaustMap.ts +++ b/src/add/operator/exhaustMap.ts @@ -1,5 +1,7 @@ import {Observable} from '../../Observable'; import {exhaustMap} from '../../operator/exhaustMap'; -Observable.prototype.exhaustMap = exhaustMap; +import {KitchenSinkOperators} from '../../Rx.KitchenSink'; +const observableProto = (>Observable.prototype); +observableProto.exhaustMap = exhaustMap; export var _void: void; \ No newline at end of file