feat(operator): add auto-patching operators

This change adds a subfolder inside of operator which contains
a module to correspond with each operator, which when imported,
will automatically patch the corresponding operator to the
Observable prototype.

Closes ReactiveX#860

src/operator/add/buffer.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {buffer} from '../buffer';
+
+
+Observable.prototype.buffer = buffer;

src/operator/add/bufferCount.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {bufferCount} from '../bufferCount';
+
+
+Observable.prototype.bufferCount = bufferCount;

src/operator/add/bufferTime.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {bufferTime} from '../bufferTime';
+
+
+Observable.prototype.bufferTime = bufferTime;

src/operator/add/bufferToggle.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {bufferToggle} from '../bufferToggle';
+
+
+Observable.prototype.bufferToggle = bufferToggle;

src/operator/add/bufferWhen.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {bufferWhen} from '../bufferWhen';
+
+
+Observable.prototype.bufferWhen = bufferWhen;

src/operator/add/catch.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {_catch} from '../catch';
+
+
+Observable.prototype.catch = _catch;

src/operator/add/combineAll.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {combineAll} from '../combineAll';
+
+
+Observable.prototype.combineAll = combineAll;

src/operator/add/combineLatest-static.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {combineLatest} from '../combineLatest-static';
+
+
+Observable.combineLatest = combineLatest;

src/operator/add/combineLatest.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {combineLatest} from '../combineLatest';
+
+
+Observable.prototype.combineLatest = combineLatest;

src/operator/add/concat-static.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {concat} from '../concat-static';
+
+
+Observable.concat = concat;

src/operator/add/concat.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {concat} from '../concat';
+
+
+Observable.prototype.concat = concat;

src/operator/add/concatAll.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {concatAll} from '../concatAll';
+
+
+Observable.prototype.concatAll = concatAll;

src/operator/add/concatMap.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {concatMap} from '../concatMap';
+
+
+Observable.prototype.concatMap = concatMap;

src/operator/add/concatMapTo.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {concatMapTo} from '../concatMapTo';
+
+
+Observable.prototype.concatMapTo = concatMapTo;

src/operator/add/count.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {count} from '../count';
+
+
+Observable.prototype.count = count;

src/operator/add/debounce.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {debounce} from '../debounce';
+
+
+Observable.prototype.debounce = debounce;

src/operator/add/debounceTime.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {debounceTime} from '../debounceTime';
+
+
+Observable.prototype.debounceTime = debounceTime;

src/operator/add/defaultIfEmpty.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {defaultIfEmpty} from '../defaultIfEmpty';
+
+
+Observable.prototype.defaultIfEmpty = defaultIfEmpty;

src/operator/add/delay.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {delay} from '../delay';
+
+
+Observable.prototype.delay = delay;

src/operator/add/dematerialize.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {dematerialize} from '../dematerialize';
+
+
+Observable.prototype.dematerialize = dematerialize;

src/operator/add/distinctUntilChanged.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {distinctUntilChanged} from '../distinctUntilChanged';
+
+
+Observable.prototype.distinctUntilChanged = distinctUntilChanged;

src/operator/add/do.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {_do} from '../do';
+
+
+Observable.prototype.do = _do;

src/operator/add/every.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {every} from '../every';
+
+
+Observable.prototype.every = every;

src/operator/add/expand.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {expand} from '../expand';
+
+
+Observable.prototype.expand = expand;

src/operator/add/extended/distinctUntilKeyChanged.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../../Observable';
+import {distinctUntilKeyChanged} from '../../extended/distinctUntilKeyChanged';
+import {KitchenSinkOperators} from '../../Rx.KitchenSink';
+const observableProto = (<KitchenSinkOperators<any>>Observable.prototype);
+observableProto.distinctUntilKeyChanged = distinctUntilKeyChanged;

src/operator/add/extended/elementAt.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../../Observable';
+import {elementAt} from '../../extended/elementAt';
+import {KitchenSinkOperators} from '../../Rx.KitchenSink';
+const observableProto = (<KitchenSinkOperators<any>>Observable.prototype);
+observableProto.elementAt = elementAt;

src/operator/add/extended/find.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../../Observable';
+import {find} from '../../extended/find';
+import {KitchenSinkOperators} from '../../Rx.KitchenSink';
+const observableProto = (<KitchenSinkOperators<any>>Observable.prototype);
+observableProto.find = find;

src/operator/add/extended/findIndex.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../../Observable';
+import {findIndex} from '../../extended/findIndex';
+import {KitchenSinkOperators} from '../../Rx.KitchenSink';
+const observableProto = (<KitchenSinkOperators<any>>Observable.prototype);
+observableProto.findIndex = findIndex;

src/operator/add/extended/isEmpty.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../../Observable';
+import {isEmpty} from '../../extended/isEmpty';
+import {KitchenSinkOperators} from '../../Rx.KitchenSink';
+const observableProto = (<KitchenSinkOperators<any>>Observable.prototype);
+observableProto.isEmpty = isEmpty;

src/operator/add/extended/max.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../../Observable';
+import {max} from '../../extended/max';
+import {KitchenSinkOperators} from '../../Rx.KitchenSink';
+const observableProto = (<KitchenSinkOperators<any>>Observable.prototype);
+observableProto.max = max;

src/operator/add/extended/mergeScan.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../../Observable';
+import {mergeScan} from '../../extended/mergeScan';
+import {KitchenSinkOperators} from '../../Rx.KitchenSink';
+const observableProto = (<KitchenSinkOperators<any>>Observable.prototype);
+observableProto.mergeScan = mergeScan;

src/operator/add/extended/min.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../../Observable';
+import {min} from '../../extended/min';
+import {KitchenSinkOperators} from '../../Rx.KitchenSink';
+const observableProto = (<KitchenSinkOperators<any>>Observable.prototype);
+observableProto.min = min;

src/operator/add/extended/timeInterval.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../../Observable';
+import {timeInterval} from '../../extended/timeInterval';
+import {KitchenSinkOperators} from '../../Rx.KitchenSink';
+const observableProto = (<KitchenSinkOperators<any>>Observable.prototype);
+observableProto.timeInterval = timeInterval;

src/operator/add/filter.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {filter} from '../filter';
+
+
+Observable.prototype.filter = filter;

src/operator/add/finally.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {_finally} from '../finally';
+
+
+Observable.prototype.finally = _finally;

src/operator/add/first.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {first} from '../first';
+
+
+Observable.prototype.first = first;

src/operator/add/groupBy.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {groupBy} from '../groupBy';
+
+
+Observable.prototype.groupBy = groupBy;

src/operator/add/ignoreElements.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {ignoreElements} from '../ignoreElements';
+
+
+Observable.prototype.ignoreElements = ignoreElements;

src/operator/add/last.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {last} from '../last';
+
+
+Observable.prototype.last = last;

src/operator/add/map.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {map} from '../map';
+
+
+Observable.prototype.map = map;

src/operator/add/mapTo.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {mapTo} from '../mapTo';
+
+
+Observable.prototype.mapTo = mapTo;

src/operator/add/materialize.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {materialize} from '../materialize';
+
+
+Observable.prototype.materialize = materialize;

src/operator/add/merge-static.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {merge} from '../merge-static';
+
+
+Observable.merge = merge;

src/operator/add/merge.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {merge} from '../merge';
+
+
+Observable.prototype.merge = merge;

src/operator/add/mergeAll.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {mergeAll} from '../mergeAll';
+
+
+Observable.prototype.mergeAll = mergeAll;

src/operator/add/mergeMap.ts

@@ -0,0 +1,6 @@
+import {Observable} from '../../Observable';
+import {mergeMap} from '../mergeMap';
+
+
+Observable.prototype.mergeMap = mergeMap;
+Observable.prototype.flatMap = mergeMap;

src/operator/add/mergeMapTo.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {mergeMapTo} from '../mergeMapTo';
+
+
+Observable.prototype.mergeMapTo = mergeMapTo;

src/operator/add/multicast.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {multicast} from '../multicast';
+
+
+Observable.prototype.multicast = multicast;

src/operator/add/observeOn.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {observeOn} from '../observeOn';
+
+
+Observable.prototype.observeOn = observeOn;

src/operator/add/partition.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {partition} from '../partition';
+
+
+Observable.prototype.partition = partition;

src/operator/add/publish.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {publish} from '../publish';
+
+
+Observable.prototype.publish = publish;

src/operator/add/publishBehavior.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {publishBehavior} from '../publishBehavior';
+
+
+Observable.prototype.publishBehavior = publishBehavior;

src/operator/add/publishReplay.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {publishReplay} from '../publishReplay';
+
+
+Observable.prototype.publishReplay = publishReplay;

src/operator/add/reduce.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {reduce} from '../reduce';
+
+
+Observable.prototype.reduce = reduce;

src/operator/add/repeat.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {repeat} from '../repeat';
+
+
+Observable.prototype.repeat = repeat;

src/operator/add/retry.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {retry} from '../retry';
+
+
+Observable.prototype.retry = retry;

src/operator/add/retryWhen.ts

@@ -0,0 +1,5 @@
+import {Observable} from '../../Observable';
+import {retryWhen} from '../retryWhen';
+
+
+Observable.prototype.retryWhen = retryWhen;