feat(reorganize): Move observable implementations under internal directory

- Moves all files from `src/observables` to `src/internal/observables`
- Updates some tests to reference those internal files, this is
temprorary
- Adds an `index.ts` file at root that exports the static observable
creation functions

BREAKING CHANGE: You can no longer import observables from
`rxjs/observable/*`, now you must import them from `rxjs` directly, like
so: `import { fromEvent, timer } from 'rxjs';`

BREAKING CHANGE: You should no longer deep import custom Observable
implementations

BREAKING CHANGE: `_throw` is now exported as `throwError`

BREAKING CHANGE: `if` is now exported as `iif`

Author: benlesh

spec/exports-spec.ts

@@ -1,28 +1,28 @@
 import { expect } from 'chai';
-import { bindCallback } from '../src/observable/bindCallback';
-import { bindNodeCallback } from '../src/observable/bindNodeCallback';
-import { combineLatest } from '../src/observable/combineLatest';
-import { concat } from '../src/observable/concat';
-import { defer } from '../src/observable/defer';
-import { empty } from '../src/observable/empty';
-import { forkJoin } from '../src/observable/forkJoin';
-import { from } from '../src/observable/from';
-import { fromEvent } from '../src/observable/fromEvent';
-import { fromEventPattern } from '../src/observable/fromEventPattern';
-import { fromPromise } from '../src/observable/fromPromise';
-import { _if } from '../src/observable/if';
-import { interval } from '../src/observable/interval';
-import { merge } from '../src/observable/merge';
-import { never } from '../src/observable/never';
-import { of } from '../src/observable/of';
-import { onErrorResumeNext } from '../src/observable/onErrorResumeNext';
-import { pairs } from '../src/observable/pairs';
-import { race } from '../src/observable/race';
-import { range } from '../src/observable/range';
-import { _throw } from '../src/observable/throw';
-import { timer } from '../src/observable/timer';
-import { using } from '../src/observable/using';
-import { zip } from '../src/observable/zip';
+import { bindCallback } from '../src/internal/observable/bindCallback';
+import { bindNodeCallback } from '../src/internal/observable/bindNodeCallback';
+import { combineLatest } from '../src/internal/observable/combineLatest';
+import { concat } from '../src/internal/observable/concat';
+import { defer } from '../src/internal/observable/defer';
+import { empty } from '../src/internal/observable/empty';
+import { forkJoin } from '../src/internal/observable/forkJoin';
+import { from } from '../src/internal/observable/from';
+import { fromEvent } from '../src/internal/observable/fromEvent';
+import { fromEventPattern } from '../src/internal/observable/fromEventPattern';
+import { fromPromise } from '../src/internal/observable/fromPromise';
+import { _if } from '../src/internal/observable/if';
+import { interval } from '../src/internal/observable/interval';
+import { merge } from '../src/internal/observable/merge';
+import { never } from '../src/internal/observable/never';
+import { of } from '../src/internal/observable/of';
+import { onErrorResumeNext } from '../src/internal/observable/onErrorResumeNext';
+import { pairs } from '../src/internal/observable/pairs';
+import { race } from '../src/internal/observable/race';
+import { range } from '../src/internal/observable/range';
+import { _throw } from '../src/internal/observable/throw';
+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';
 
 describe('exports', () => {
@@ -121,4 +121,4 @@ describe('exports', () => {
   it('should have rxjs/observable/zip', () => {
     expect(zip).to.equal(Rx.Observable.zip);
   });
-});
+});

spec/index-spec.ts

@@ -0,0 +1,31 @@
+import * as index from '../src/index';
+import { expect } from 'chai';
+
+describe('index', () => {
+  it('should export static observable creator functions', () => {
+    expect(index.bindCallback).to.exist;
+    expect(index.bindNodeCallback).to.exist;
+    expect(index.combineLatest).to.exist;
+    expect(index.concat).to.exist;
+    expect(index.defer).to.exist;
+    expect(index.empty).to.exist;
+    expect(index.forkJoin).to.exist;
+    expect(index.from).to.exist;
+    expect(index.fromEvent).to.exist;
+    expect(index.fromEventPattern).to.exist;
+    expect(index.generate).to.exist;
+    expect(index.iif).to.exist;
+    expect(index.interval).to.exist;
+    expect(index.merge).to.exist;
+    expect(index.never).to.exist;
+    expect(index.of).to.exist;
+    expect(index.onErrorResumeNext).to.exist;
+    expect(index.pairs).to.exist;
+    expect(index.race).to.exist;
+    expect(index.range).to.exist;
+    expect(index.throwError).to.exist;
+    expect(index.timer).to.exist;
+    expect(index.using).to.exist;
+    expect(index.zip).to.exist;
+  });
+});

spec/observables/IteratorObservable-spec.ts

@@ -1,7 +1,7 @@
 import { expect } from 'chai';
 import * as Rx from '../../src/Rx';
 import { queue } from '../../src/scheduler/queue';
-import { IteratorObservable } from '../../src/observable/IteratorObservable';
+import { IteratorObservable } from '../../src/internal/observable/IteratorObservable';
 
 declare const expectObservable;
 declare const rxTestScheduler: Rx.TestScheduler;

spec/observables/ScalarObservable-spec.ts

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

spec/observables/SubscribeOnObservable-spec.ts

@@ -1,7 +1,7 @@
 import { expect } from 'chai';
 import * as sinon from 'sinon';
 import * as Rx from '../../src/Rx';
-import { SubscribeOnObservable } from '../../src/observable/SubscribeOnObservable';
+import { SubscribeOnObservable } from '../../src/internal/observable/SubscribeOnObservable';
 import marbleTestingSignature = require('../helpers/marble-testing'); // tslint:disable-line:no-require-imports
 
 declare const hot: typeof marbleTestingSignature.hot;

spec/observables/of-spec.ts

@@ -1,8 +1,8 @@
 import { expect } from 'chai';
 import * as Rx from '../../src/Rx';
-import { ArrayObservable } from '../../src/observable/ArrayObservable';
-import { ScalarObservable } from '../../src/observable/ScalarObservable';
-import { EmptyObservable } from '../../src/observable/EmptyObservable';
+import { ArrayObservable } from '../../src/internal/observable/ArrayObservable';
+import { ScalarObservable } from '../../src/internal/observable/ScalarObservable';
+import { EmptyObservable } from '../../src/internal/observable/EmptyObservable';
 import marbleTestingSignature = require('../helpers/marble-testing'); // tslint:disable-line:no-require-imports
 
 declare const { asDiagram };

spec/observables/range-spec.ts

@@ -1,7 +1,7 @@
 import { expect } from 'chai';
 import * as sinon from 'sinon';
 import * as Rx from '../../src/Rx';
-import { RangeObservable } from '../../src/observable/RangeObservable';
+import { RangeObservable } from '../../src/internal/observable/RangeObservable';
 import marbleTestingSignature = require('../helpers/marble-testing'); // tslint:disable-line:no-require-imports
 
 declare const { asDiagram };

spec/observables/throw-spec.ts

@@ -1,6 +1,6 @@
 import { expect } from 'chai';
 import * as Rx from '../../src/Rx';
-import { ErrorObservable } from '../../src/observable/ErrorObservable';
+import { ErrorObservable } from '../../src/internal/observable/ErrorObservable';
 import marbleTestingSignature = require('../helpers/marble-testing'); // tslint:disable-line:no-require-imports
 
 declare const { asDiagram };

src/MiscJSDoc.ts

@@ -7,7 +7,7 @@
  */
 import { TeardownLogic } from './Subscription';
 import { Observable } from './Observable';
-import './observable/dom/MiscJSDoc';
+import './internal/observable/dom/MiscJSDoc';
 import { Observer } from './Observer';
 
 /**

src/Notification.ts

@@ -1,5 +1,8 @@
 import { PartialObserver } from './Observer';
 import { Observable } from './Observable';
+import { empty } from './internal/observable/empty';
+import { of } from './internal/observable/of';
+import { _throw } from './internal/observable/throw';
 
 /**
  * Represents a push-based event or value that an {@link Observable} can emit.
@@ -84,11 +87,11 @@ export class Notification<T> {
     const kind = this.kind;
     switch (kind) {
       case 'N':
-        return Observable.of(this.value);
+        return of(this.value);
       case 'E':
-        return Observable.throw(this.error);
+        return _throw(this.error);
       case 'C':
-        return Observable.empty<T>();
+        return empty<T>();
     }
     throw new Error('unexpected notification kind value');
   }