Skip to content

Commit

Permalink
feat(reorganize): All patch operators moved to internal directory
Browse files Browse the repository at this point in the history
Moves all patching operator implementations to a directory `internal/patching/operator`.

BREAKING CHANGE: Deep imports to `rxjs/operator/*` (NOT
`rxjs/operators/*`!!!) will no longer work. Again, pipe operators are
still where they were.
  • Loading branch information
benlesh committed Jan 12, 2018
1 parent 1c41825 commit 7342401
Show file tree
Hide file tree
Showing 204 changed files with 460 additions and 462 deletions.
2 changes: 1 addition & 1 deletion src/Rx.ts
Original file line number Diff line number Diff line change
Expand Up @@ -157,7 +157,7 @@ export {ArgumentOutOfRangeError} from './util/ArgumentOutOfRangeError';
export {ObjectUnsubscribedError} from './util/ObjectUnsubscribedError';
export {TimeoutError} from './util/TimeoutError';
export {UnsubscriptionError} from './util/UnsubscriptionError';
export {TimeInterval} from './operator/timeInterval';
export {TimeInterval} from './internal/patching/operator/timeInterval';
export {Timestamp} from './operators/timestamp';
export {TestScheduler} from './testing/TestScheduler';
export {VirtualTimeScheduler} from './scheduler/VirtualTimeScheduler';
Expand Down
4 changes: 2 additions & 2 deletions src/add/operator/audit.ts
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
import { Observable } from '../../Observable';
import { audit } from '../../operator/audit';
import { audit } from '../../internal/patching/operator/audit';

Observable.prototype.audit = audit;

declare module '../../Observable' {
interface Observable<T> {
audit: typeof audit;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/auditTime.ts
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
import { Observable } from '../../Observable';
import { auditTime } from '../../operator/auditTime';
import { auditTime } from '../../internal/patching/operator/auditTime';

Observable.prototype.auditTime = auditTime;

declare module '../../Observable' {
interface Observable<T> {
auditTime: typeof auditTime;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/buffer.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { buffer } from '../../operator/buffer';
import { buffer } from '../../internal/patching/operator/buffer';

Observable.prototype.buffer = buffer;

declare module '../../Observable' {
interface Observable<T> {
buffer: typeof buffer;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/bufferCount.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { bufferCount } from '../../operator/bufferCount';
import { bufferCount } from '../../internal/patching/operator/bufferCount';

Observable.prototype.bufferCount = bufferCount;

declare module '../../Observable' {
interface Observable<T> {
bufferCount: typeof bufferCount;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/bufferTime.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { bufferTime } from '../../operator/bufferTime';
import { bufferTime } from '../../internal/patching/operator/bufferTime';

Observable.prototype.bufferTime = bufferTime;

declare module '../../Observable' {
interface Observable<T> {
bufferTime: typeof bufferTime;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/bufferToggle.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { bufferToggle } from '../../operator/bufferToggle';
import { bufferToggle } from '../../internal/patching/operator/bufferToggle';

Observable.prototype.bufferToggle = bufferToggle;

declare module '../../Observable' {
interface Observable<T> {
bufferToggle: typeof bufferToggle;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/bufferWhen.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { bufferWhen } from '../../operator/bufferWhen';
import { bufferWhen } from '../../internal/patching/operator/bufferWhen';

Observable.prototype.bufferWhen = bufferWhen;

declare module '../../Observable' {
interface Observable<T> {
bufferWhen: typeof bufferWhen;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/catch.ts
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@

import { Observable } from '../../Observable';
import { _catch } from '../../operator/catch';
import { _catch } from '../../internal/patching/operator/catch';

Observable.prototype.catch = _catch;
Observable.prototype._catch = _catch;
Expand All @@ -10,4 +10,4 @@ declare module '../../Observable' {
catch: typeof _catch;
_catch: typeof _catch;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/combineAll.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { combineAll } from '../../operator/combineAll';
import { combineAll } from '../../internal/patching/operator/combineAll';

Observable.prototype.combineAll = combineAll;

declare module '../../Observable' {
interface Observable<T> {
combineAll: typeof combineAll;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/combineLatest.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { combineLatest } from '../../operator/combineLatest';
import { combineLatest } from '../../internal/patching/operator/combineLatest';

Observable.prototype.combineLatest = combineLatest;

declare module '../../Observable' {
interface Observable<T> {
combineLatest: typeof combineLatest;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/concat.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { concat } from '../../operator/concat';
import { concat } from '../../internal/patching/operator/concat';

Observable.prototype.concat = concat;

declare module '../../Observable' {
interface Observable<T> {
concat: typeof concat;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/concatAll.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { concatAll } from '../../operator/concatAll';
import { concatAll } from '../../internal/patching/operator/concatAll';

Observable.prototype.concatAll = concatAll;

declare module '../../Observable' {
interface Observable<T> {
concatAll: typeof concatAll;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/concatMap.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { concatMap } from '../../operator/concatMap';
import { concatMap } from '../../internal/patching/operator/concatMap';

Observable.prototype.concatMap = concatMap;

declare module '../../Observable' {
interface Observable<T> {
concatMap: typeof concatMap;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/concatMapTo.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { concatMapTo } from '../../operator/concatMapTo';
import { concatMapTo } from '../../internal/patching/operator/concatMapTo';

Observable.prototype.concatMapTo = concatMapTo;

declare module '../../Observable' {
interface Observable<T> {
concatMapTo: typeof concatMapTo;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/count.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { count } from '../../operator/count';
import { count } from '../../internal/patching/operator/count';

Observable.prototype.count = count;

declare module '../../Observable' {
interface Observable<T> {
count: typeof count;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/debounce.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { debounce } from '../../operator/debounce';
import { debounce } from '../../internal/patching/operator/debounce';

Observable.prototype.debounce = debounce;

declare module '../../Observable' {
interface Observable<T> {
debounce: typeof debounce;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/debounceTime.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { debounceTime } from '../../operator/debounceTime';
import { debounceTime } from '../../internal/patching/operator/debounceTime';

Observable.prototype.debounceTime = debounceTime;

declare module '../../Observable' {
interface Observable<T> {
debounceTime: typeof debounceTime;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/defaultIfEmpty.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { defaultIfEmpty } from '../../operator/defaultIfEmpty';
import { defaultIfEmpty } from '../../internal/patching/operator/defaultIfEmpty';

Observable.prototype.defaultIfEmpty = defaultIfEmpty;

declare module '../../Observable' {
interface Observable<T> {
defaultIfEmpty: typeof defaultIfEmpty;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/delay.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { delay } from '../../operator/delay';
import { delay } from '../../internal/patching/operator/delay';

Observable.prototype.delay = delay;

declare module '../../Observable' {
interface Observable<T> {
delay: typeof delay;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/delayWhen.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { delayWhen } from '../../operator/delayWhen';
import { delayWhen } from '../../internal/patching/operator/delayWhen';

Observable.prototype.delayWhen = delayWhen;

declare module '../../Observable' {
interface Observable<T> {
delayWhen: typeof delayWhen;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/dematerialize.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { dematerialize } from '../../operator/dematerialize';
import { dematerialize } from '../../internal/patching/operator/dematerialize';

Observable.prototype.dematerialize = dematerialize;

declare module '../../Observable' {
interface Observable<T> {
dematerialize: typeof dematerialize;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/distinct.ts
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
import { Observable } from '../../Observable';
import { distinct } from '../../operator/distinct';
import { distinct } from '../../internal/patching/operator/distinct';

Observable.prototype.distinct = distinct;

declare module '../../Observable' {
interface Observable<T> {
distinct: typeof distinct;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/distinctUntilChanged.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { distinctUntilChanged } from '../../operator/distinctUntilChanged';
import { distinctUntilChanged } from '../../internal/patching/operator/distinctUntilChanged';

Observable.prototype.distinctUntilChanged = distinctUntilChanged;

declare module '../../Observable' {
interface Observable<T> {
distinctUntilChanged: typeof distinctUntilChanged;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/distinctUntilKeyChanged.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { distinctUntilKeyChanged } from '../../operator/distinctUntilKeyChanged';
import { distinctUntilKeyChanged } from '../../internal/patching/operator/distinctUntilKeyChanged';

Observable.prototype.distinctUntilKeyChanged = distinctUntilKeyChanged;

declare module '../../Observable' {
interface Observable<T> {
distinctUntilKeyChanged: typeof distinctUntilKeyChanged;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/do.ts
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@

import { Observable } from '../../Observable';
import { _do } from '../../operator/do';
import { _do } from '../../internal/patching/operator/do';

Observable.prototype.do = _do;
Observable.prototype._do = _do;
Expand All @@ -10,4 +10,4 @@ declare module '../../Observable' {
do: typeof _do;
_do: typeof _do;
}
}
}
4 changes: 2 additions & 2 deletions src/add/operator/elementAt.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@

import { Observable } from '../../Observable';
import { elementAt } from '../../operator/elementAt';
import { elementAt } from '../../internal/patching/operator/elementAt';

Observable.prototype.elementAt = elementAt;

declare module '../../Observable' {
interface Observable<T> {
elementAt: typeof elementAt;
}
}
}
Loading

0 comments on commit 7342401

Please sign in to comment.