refactor(Rx.ts): move Rx.ts to internal (#3400)

BREAKING CHANGE: importing from `rxjs/Rx` is no longer available. Upcoming backwards compat solution will allow that

package.json

@@ -96,7 +96,7 @@
     "compile_dist_cjs": "tsc -p ./tsconfig/tsconfig.cjs.json",
     "compile_dist_esm5": "tsc -p ./tsconfig/tsconfig.esm5.json",
     "compile_dist_esm2015": "tsc -p ./tsconfig/tsconfig.esm2015.json",
-    "compile_dist_esm2015_for_docs": "tsc ./dist/src/Rx.ts ./dist/src/add/observable/of.ts ./dist/src/MiscJSDoc.ts -m es2015   --sourceMap --outDir ./dist/es6 --target es2015 -d --diagnostics --pretty --noImplicitAny --noImplicitReturns --noImplicitThis --suppressImplicitAnyIndexErrors --moduleResolution node",
+    "compile_dist_esm2015_for_docs": "tsc ./dist/src/internal/Rx.ts ./dist/src/add/observable/of.ts ./dist/src/MiscJSDoc.ts -m es2015   --sourceMap --outDir ./dist/es6 --target es2015 -d --diagnostics --pretty --noImplicitAny --noImplicitReturns --noImplicitThis --suppressImplicitAnyIndexErrors --moduleResolution node",
     "compile_dist_esm5_for_rollup": "tsc -p ./tsconfig/tsconfig.esm5.rollup.json",
     "copy_sources": "mkdirp dist && shx cp -r ./src/ ./dist/src",
     "decision_tree_widget": "cd doc/decision-tree-widget && npm run build && cd ../..",

spec/Notification-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../src/Rx';
+import * as Rx from '../src/internal/Rx';
 import { expectObservable } from './helpers/marble-testing';
 
 const Notification = Rx.Notification;

spec/Observable-spec.ts

@@ -1,6 +1,6 @@
 import { expect } from 'chai';
 import * as sinon from 'sinon';
-import * as Rx from '../src/Rx';
+import * as Rx from '../src/internal/Rx';
 import { Observer, TeardownLogic } from '../src/internal/types';
 import { cold, expectObservable, expectSubscriptions } from './helpers/marble-testing';
 import { map } from '../src/internal/operators/map';

spec/Scheduler-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../src/Rx';
+import * as Rx from '../src/internal/Rx';
 
 const Scheduler = Rx.Scheduler;
 

spec/Subject-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../src/Rx';
+import * as Rx from '../src/internal/Rx';
 import { hot, expectObservable } from './helpers/marble-testing';
 
 const Subject = Rx.Subject;

spec/Subscriber-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../src/Rx';
+import * as Rx from '../src/internal/Rx';
 
 const Subscriber = Rx.Subscriber;
 

spec/Subscription-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../src/Rx';
+import * as Rx from '../src/internal/Rx';
 
 const Observable = Rx.Observable;
 const Subscription = Rx.Subscription;

spec/exports-spec.ts

@@ -23,7 +23,7 @@ import { throwError } from '../src/internal/observable/throwError';
 import { timer } from '../src/internal/observable/timer';
 import { using } from '../src/internal/observable/using';
 import { zip } from '../src/internal/observable/zip';
-import * as Rx from '../src/Rx';
+import * as Rx from '../src/internal/Rx';
 
 describe('exports', () => {
   it('should have rxjs/observable/bindCallback', () => {

spec/helpers/test-helper.ts

@@ -1,6 +1,6 @@
 declare const global: any;
 
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { ObservableInput } from '../../src/internal/types';
 import { root } from '../../src/internal/util/root';
 import { $$iterator } from '../../src/internal/symbol/iterator';

spec/helpers/testScheduler-ui.ts

@@ -4,7 +4,7 @@ import * as _ from 'lodash';
 import * as chai from 'chai';
 import * as sinonChai from 'sinon-chai';
 
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import * as marble from './marble-testing';
 
 //tslint:disable:no-var-requires no-require-imports

spec/observables/IteratorObservable-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { queue } from '../../src/internal/scheduler/queue';
 import { fromIterable } from '../../src/internal/observable/fromIterable';
 

spec/observables/ScalarObservable-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { scalar } from '../../src/internal/observable/scalar';
 
 declare const rxTestScheduler: Rx.TestScheduler;

spec/observables/SubscribeOnObservable-spec.ts

@@ -1,6 +1,6 @@
 import { expect } from 'chai';
 import * as sinon from 'sinon';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { SubscribeOnObservable } from '../../src/internal/observable/SubscribeOnObservable';
 import { hot, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 

spec/observables/bindCallback-spec.ts

@@ -1,6 +1,6 @@
 import { expect } from 'chai';
 import * as sinon from 'sinon';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 
 declare const rxTestScheduler: Rx.TestScheduler;
 const Observable = Rx.Observable;

spec/observables/combineLatest-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare const type: Function;

spec/observables/concat-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { lowerCaseO } from '../helpers/test-helper';
 import { hot, cold, emptySubs, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 

spec/observables/dom/ajax-spec.ts

@@ -1,6 +1,6 @@
 import { expect } from 'chai';
 import * as sinon from 'sinon';
-import * as Rx from '../../../src/Rx';
+import * as Rx from '../../../src/internal/Rx';
 import { root } from '../../../src/internal/util/root';
 
 declare const global: any;

spec/observables/dom/webSocket-spec.ts

@@ -1,6 +1,6 @@
 import { expect } from 'chai';
 import * as sinon from 'sinon';
-import * as Rx from '../../../src/Rx';
+import * as Rx from '../../../src/internal/Rx';
 
 declare const __root__: any;
 
@@ -705,4 +705,4 @@ class MockWebSocket {
       }
     }
   }
-}
+}

spec/observables/from-promise-spec.ts

@@ -1,6 +1,6 @@
 import { expect } from 'chai';
 import * as sinon from 'sinon';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 
 declare const process: any;
 const Observable = Rx.Observable;

spec/observables/generate-spec.ts

@@ -1,4 +1,4 @@
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import '../../src/add/observable/generate';
 import { TestScheduler } from '../../src/internal/testing/TestScheduler';
 import { expect } from 'chai';

spec/observables/merge-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { lowerCaseO } from '../helpers/test-helper';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 

spec/observables/of-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { empty } from '../../src/internal/observable/empty';
 import { expectObservable } from '../helpers/marble-testing';
 declare const asDiagram: any;

spec/observables/race-spec.ts

@@ -1,4 +1,4 @@
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 const Observable = Rx.Observable;

spec/observables/using-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 
 const Observable = Rx.Observable;
 const Subscription = Rx.Subscription;

spec/observables/zip-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare const type: Function;

spec/operators/audit-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;

spec/operators/auditTime-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;

spec/operators/buffer-spec.ts

@@ -1,4 +1,4 @@
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;

spec/operators/bufferCount-spec.ts

@@ -1,4 +1,4 @@
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { expect } from 'chai';
 import { hot, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
@@ -140,4 +140,4 @@ describe('Observable.prototype.bufferCount', () => {
     expectObservable(e1.bufferCount(2, 3)).toBe(expected, values);
     expectSubscriptions(e1.subscriptions).toBe(e1subs);
   });
-});
+});

spec/operators/bufferTime-spec.ts

@@ -1,4 +1,4 @@
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions, time } from '../helpers/marble-testing';
 
 declare const asDiagram: Function;
@@ -321,4 +321,4 @@ describe('Observable.prototype.bufferTime', () => {
 
     expectObservable(source).toBe(expected, values);
   });
-});
+});

spec/operators/bufferToggle-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;

spec/operators/bufferWhen-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;

spec/operators/catch-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import * as sinon from 'sinon';
 import { createObservableInputs } from '../helpers/test-helper';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';

spec/operators/combineAll-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;

spec/operators/combineLatest-spec.ts

@@ -1,4 +1,4 @@
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;

spec/operators/concat-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;

spec/operators/concatAll-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 import { throwError } from '../../src/internal/observable/throwError';
 

spec/operators/concatMap-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;

spec/operators/concatMapTo-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;

spec/operators/count-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;

spec/operators/debounce-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare const type;

spec/operators/debounceTime-spec.ts

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 import { VirtualTimeScheduler } from '../../src/internal/scheduler/VirtualTimeScheduler';
 

spec/operators/defaultIfEmpty-spec.ts

@@ -1,4 +1,4 @@
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;

spec/operators/delay-spec.ts

@@ -1,4 +1,4 @@
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions, time } from '../helpers/marble-testing';
 
 declare const asDiagram: Function;
@@ -143,4 +143,4 @@ describe('Observable.prototype.delay', () => {
 
     expectObservable(result).toBe(expected);
   });
-});
+});

spec/operators/delayWhen-spec.ts

@@ -1,4 +1,4 @@
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 import { expect } from 'chai';
 
@@ -225,4 +225,4 @@ describe('Observable.prototype.delayWhen', () => {
     expect(next).to.be.true;
     expect(complete).to.be.true;
   });
-});
+});

spec/operators/dematerialize-spec.ts

@@ -1,4 +1,4 @@
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;
@@ -162,4 +162,4 @@ describe('Observable.prototype.dematerialize', () => {
     expectObservable(e1.dematerialize()).toBe(expected);
     expectSubscriptions(e1.subscriptions).toBe(e1subs);
   });
-});
+});

spec/operators/distinct-spec.ts

@@ -1,4 +1,4 @@
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 const Observable = Rx.Observable;
@@ -212,4 +212,4 @@ describe('Observable.prototype.distinct', () => {
     expectSubscriptions(e1.subscriptions).toBe(e1subs);
     expectSubscriptions(e2.subscriptions).toBe(e2subs);
   });
-});
+});

spec/operators/distinctUntilChanged-spec.ts

@@ -1,4 +1,4 @@
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;

spec/operators/distinctUntilKeyChanged-spec.ts

@@ -1,4 +1,4 @@
-import * as Rx from '../../src/Rx';
+import * as Rx from '../../src/internal/Rx';
 import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
 
 declare function asDiagram(arg: string): Function;
@@ -223,4 +223,4 @@ describe('Observable.prototype.distinctUntilKeyChanged', () => {
     expectObservable((<any>e1).distinctUntilKeyChanged('val', selector)).toBe(expected, values);
     expectSubscriptions(e1.subscriptions).toBe(e1subs);
   });
-});
+});