Skip to content

Commit

Permalink
refactor(Observable): remove exhaust from core rx
Browse files Browse the repository at this point in the history
  • Loading branch information
kwonoj committed Dec 22, 2015
1 parent bc34cbc commit 0f38730
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 4 deletions.
2 changes: 0 additions & 2 deletions src/Observable.ts
Original file line number Diff line number Diff line change
Expand Up @@ -257,9 +257,7 @@ export class Observable<T> implements CoreOperators<T> {
startWith: (x: T) => Observable<T>;
subscribeOn: (scheduler: Scheduler, delay?: number) => Observable<T>;
switch: <R>() => Observable<R>;
exhaust: <T>() => Observable<T>;
switchMap: <R>(project: ((x: T, ix: number) => Observable<any>), projectResult?: (x: T, y: any, ix: number, iy: number) => R) => Observable<R>;
exhaustMap: <T, R, R2>(project: (x: T, ix: number) => Observable<R>, rSelector?: (x: T, y: R, ix: number, iy: number) => R2) => Observable<R>;
switchMapTo: <R>(observable: Observable<any>, projectResult?: (x: T, y: any, ix: number, iy: number) => R) => Observable<R>;
take: (count: number) => Observable<T>;
takeUntil: (notifier: Observable<any>) => Observable<T>;
Expand Down
4 changes: 3 additions & 1 deletion src/add/operator/exhaust.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
import {Observable} from '../../Observable';
import {exhaust} from '../../operator/exhaust';
Observable.prototype.exhaust = exhaust;
import {KitchenSinkOperators} from '../../Rx.KitchenSink';
const observableProto = (<KitchenSinkOperators<any>>Observable.prototype);
observableProto.exhaust = exhaust;

export var _void: void;
4 changes: 3 additions & 1 deletion src/add/operator/exhaustMap.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
import {Observable} from '../../Observable';
import {exhaustMap} from '../../operator/exhaustMap';
Observable.prototype.exhaustMap = exhaustMap;
import {KitchenSinkOperators} from '../../Rx.KitchenSink';
const observableProto = (<KitchenSinkOperators<any>>Observable.prototype);
observableProto.exhaustMap = exhaustMap;

export var _void: void;

0 comments on commit 0f38730

Please sign in to comment.