chore(src): use named exports everywhere

refactors entire codebase to use named ES6 exports instead of default exports.

BREAKING CHANGE: commonjs users must import named exports when not importing from Rx.js or Rx.KitchenSink.js, eg:
```js
//before
var Observable = require('@reactivex/rxjs/dist/cjs/Observable');
//after
var Observable = require('@reactivex/rxjs/dist/cjs/Observable').Observable;
```

package.json

@@ -14,7 +14,7 @@
  "scripts": {
  "build_all": "npm run build_es6 && npm run build_amd && npm run build_cjs && npm run build_global",
  "build_amd": "rm -rf dist/amd && tsc typings/es6-shim/es6-shim.d.ts src/Rx.ts -m amd --outDir dist/amd --sourcemap --target ES5 --diagnostics",
- "build_cjs": "rm -rf dist/cjs && babel dist/es6 --out-dir dist/cjs --modules common --source-maps --loose all && node lib/copy_dts.js",
+ "build_cjs": "rm -rf dist/cjs && tsc typings/es6-shim/es6-shim.d.ts src/Rx.ts src/Rx.KitchenSink.ts -m commonjs --outDir dist/cjs --sourcemap --target ES5 -d --diagnostics",
  "build_es6": "rm -rf dist/es6 && tsc src/Rx.ts src/Rx.KitchenSink.ts --outDir dist/es6 --sourceMap --target ES6 -d --diagnostics",
  "build_closure": "java -jar ./node_modules/google-closure-compiler/compiler.jar ./dist/global/Rx.js --create_source_map ./dist/global/Rx.min.js.map --js_output_file ./dist/global/Rx.min.js",
  "build_global": "rm -rf dist/global && mkdir \"dist/global\" && browserify src/Rx.global.js --outfile dist/global/Rx.js && npm run build_closure",
@@ -76,8 +76,6 @@
  },
  "homepage": "https://github.com/ReactiveX/RxJS",
  "devDependencies": {
- "babel": "5.8.23",
- "babelify": "6.1.2",
  "benchmark": "1.0.0",
  "benchpress": "2.0.0-alpha.37.2",
  "browserify": "11.0.0",

spec/observables/ScalarObservable-spec.js

@@ -1,8 +1,8 @@
 /* globals describe, it, expect, rxTestScheduler*/
 var Rx = require('../../dist/cjs/Rx');
-var ScalarObservable = require('../../dist/cjs/observables/ScalarObservable');
-var EmptyObservable = require('../../dist/cjs/observables/EmptyObservable');
-var ErrorObservable = require('../../dist/cjs/observables/ErrorObservable');
+var ScalarObservable = require('../../dist/cjs/observables/ScalarObservable').ScalarObservable;
+var EmptyObservable = require('../../dist/cjs/observables/EmptyObservable').EmptyObservable;
+var ErrorObservable = require('../../dist/cjs/observables/ErrorObservable').ErrorObservable;
 var Observable = Rx.Observable;
 
 describe('ScalarObservable', function () {

spec/observables/SubscribeOnObservable-spec.js

@@ -1,6 +1,6 @@
 /* globals describe, it, expect, hot, expectObservable, expectSubscriptions, rxTestScheduler */
 var Rx = require('../../dist/cjs/Rx');
-var SubscribeOnObservable = require('../../dist/cjs/observables/SubscribeOnObservable');
+var SubscribeOnObservable = require('../../dist/cjs/observables/SubscribeOnObservable').SubscribeOnObservable;
 var Observable = Rx.Observable;
 
 describe('SubscribeOnObservable', function () {

spec/observables/from-spec.js

@@ -2,7 +2,7 @@
 var Rx = require('../../dist/cjs/Rx');
 var Promise = require('promise');
 var Observable = Rx.Observable;
-var $$iterator = require('../../dist/cjs/util/Symbol_iterator');
+var $$iterator = require('../../dist/cjs/util/Symbol_iterator').$$iterator;
 
 describe('Observable.from', function () {
  it('should enumerate an Array', function (done) {

spec/observables/of-spec.js

@@ -1,8 +1,8 @@
 /* globals describe, it, expect, expectObservable, rxTestScheduler */
 var Rx = require('../../dist/cjs/Rx');
-var ArrayObservable = require('../../dist/cjs/observables/ArrayObservable');
-var ScalarObservable = require('../../dist/cjs/observables/ScalarObservable');
-var EmptyObservable = require('../../dist/cjs/observables/EmptyObservable');
+var ArrayObservable = require('../../dist/cjs/observables/ArrayObservable').ArrayObservable;
+var ScalarObservable = require('../../dist/cjs/observables/ScalarObservable').ScalarObservable;
+var EmptyObservable = require('../../dist/cjs/observables/EmptyObservable').EmptyObservable;
 var Observable = Rx.Observable;
 
 describe('Observable.of', function () {

spec/observables/range-spec.js

@@ -1,5 +1,5 @@
 var Rx = require('../../dist/cjs/Rx');
-var RangeObservable = require('../../dist/cjs/observables/RangeObservable');
+var RangeObservable = require('../../dist/cjs/observables/RangeObservable').RangeObservable;
 var Observable = Rx.Observable;
 var nextTick = Rx.Scheduler.nextTick;
 

spec/util/MapPolyfill-spec.js

@@ -1,4 +1,4 @@
-var MapPolyfill = require('../../dist/cjs/util/MapPolyfill');
+var MapPolyfill = require('../../dist/cjs/util/MapPolyfill').MapPolyfill;
 
 describe('MapPolyfill', function () {
  it('should exist', function () {

spec/utils/bindcallback-spec.js

@@ -1,6 +1,6 @@
 /* globals describe, it, expect */
 var Rx = require('../../dist/cjs/Rx');
-var bindCallback = require('../../dist/cjs/util/bindCallback');
+var bindCallback = require('../../dist/cjs/util/bindCallback').bindCallback;
 
 describe('bindCallback', function () {
  it('should bind function has no parameter', function () {

src/CoreOperators.ts

@@ -1,9 +1,9 @@
-import Observable from './Observable';
-import Scheduler from './Scheduler';
-import ConnectableObservable from './observables/ConnectableObservable';
-import Subject from './Subject';
+import {Observable} from './Observable';
+import {Scheduler} from './Scheduler';
+import {ConnectableObservable} from './observables/ConnectableObservable';
+import {Subject} from './Subject';
 import {GroupedObservable} from './operators/groupBy-support';
-import Notification from './Notification';
+import {Notification} from './Notification';
 
 export interface CoreOperators<T> {
  buffer?: (closingNotifier: Observable<any>) => Observable<T[]>;

src/InnerSubscriber.ts

@@ -1,10 +1,10 @@
-import Subscriber from './Subscriber';
-import Observer from './Observer';
-import OuterSubscriber from './OuterSubscriber';
-import tryCatch from './util/tryCatch';
-import { errorObject } from './util/errorObject';
+import {Subscriber} from './Subscriber';
+import {Observer} from './Observer';
+import {OuterSubscriber} from './OuterSubscriber';
+import {tryCatch} from './util/tryCatch';
+import {errorObject} from './util/errorObject';
 
-export default class InnerSubscriber<T, R> extends Subscriber<R> {
+export class InnerSubscriber<T, R> extends Subscriber<R> {
  index: number = 0;
 
  constructor(private parent: OuterSubscriber<T, R>, private outerValue: T, private outerIndex: number) {

src/Notification.ts

@@ -1,7 +1,7 @@
-import Observer from './Observer';
-import Observable from './Observable';
+import {Observer} from './Observer';
+import {Observable} from './Observable';
 
-export default class Notification<T> {
+export class Notification<T> {
  hasValue: boolean;
 
  constructor(public kind: string, public value?: T, public exception?: any) {

src/Observable.ts

@@ -1,23 +1,23 @@
-import Observer from './Observer';
-import Operator from './Operator';
-import Scheduler from './Scheduler';
-import Subscriber from './Subscriber';
-import Subscription from './Subscription';
-import { root } from './util/root';
-import { CoreOperators } from './CoreOperators';
-import $$observable from './util/Symbol_observable';
-import { GroupedObservable } from './operators/groupBy-support';
-import ConnectableObservable from './observables/ConnectableObservable';
-import Subject from './Subject';
-import Notification from './Notification';
+import {Observer} from './Observer';
+import {Operator} from './Operator';
+import {Scheduler} from './Scheduler';
+import {Subscriber} from './Subscriber';
+import {Subscription} from './Subscription';
+import {root} from './util/root';
+import {CoreOperators } from './CoreOperators';
+import {$$observable} from './util/Symbol_observable';
+import {GroupedObservable} from './operators/groupBy-support';
+import {ConnectableObservable} from './observables/ConnectableObservable';
+import {Subject} from './Subject';
+import {Notification} from './Notification';
 
 /**
  * A representation of any set of values over any amount of time. This the most basic building block
  * of RxJS.
  *
  * @class Observable<T>
  */
-export default class Observable<T> implements CoreOperators<T> {
+export class Observable<T> implements CoreOperators<T> {
  source: Observable<any>;
  operator: Operator<any, T>;
  _isScalar: boolean = false;

src/Observer.ts

@@ -1,8 +1,6 @@
-interface Observer<T> {
+export interface Observer<T> {
  next(value: T): void;
  error(err?: any): void;
  complete(): void;
  isUnsubscribed: boolean;
-}
-
-export default Observer;
+}

src/Operator.ts

@@ -1,12 +1,10 @@
-import Observer from './Observer';
-import Subscriber from './Subscriber';
+import {Observer} from './Observer';
+import {Subscriber} from './Subscriber';
 
-interface Operator<T, R> {
+export interface Operator<T, R> {
  call<T, R>(subscriber: Subscriber<R>): Subscriber<T>;
 }
 
-export default Operator;
-
 export function defaultCallFn<T, R>(observer: Observer<R>): Observer<T> {
  return new Subscriber<T>(observer);
 }

src/OuterSubscriber.ts

@@ -1,7 +1,7 @@
-import InnerSubscriber from './InnerSubscriber';
-import Subscriber from './Subscriber';
+import {InnerSubscriber} from './InnerSubscriber';
+import {Subscriber} from './Subscriber';
 
-export default class OuterSubscriber<T, R> extends Subscriber<T> {
+export class OuterSubscriber<T, R> extends Subscriber<T> {
  notifyComplete(inner?: InnerSubscriber<T, R>): void {
  this.destination.complete();
  }