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/add/buffer.ts

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

src/add/bufferCount.ts

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

src/add/bufferTime.ts

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

src/add/bufferToggle.ts

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

src/add/bufferWhen.ts

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

src/add/catch.ts

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

src/add/combineAll.ts

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

src/add/combineLatest-static.ts

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

src/add/combineLatest.ts

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

src/add/concat-static.ts

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

src/add/concat.ts

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

src/add/concatAll.ts

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

src/add/concatMap.ts

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

src/add/concatMapTo.ts

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

src/add/count.ts

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

src/add/debounce.ts

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

src/add/debounceTime.ts

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

src/add/defaultIfEmpty.ts

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

src/add/delay.ts

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

src/add/dematerialize.ts

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

src/add/distinctUntilChanged.ts

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

src/add/do.ts

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

src/add/every.ts

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

src/add/expand.ts

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

src/add/extended/distinctUntilKeyChanged.ts

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

src/add/extended/elementAt.ts

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

src/add/extended/find.ts

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

src/add/extended/findIndex.ts

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

src/add/extended/isEmpty.ts

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

src/add/extended/max.ts

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

src/add/extended/mergeScan.ts

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

src/add/extended/min.ts

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

src/add/extended/timeInterval.ts

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

src/add/filter.ts

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

src/add/finally.ts

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

src/add/first.ts

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

src/add/groupBy.ts

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

src/add/ignoreElements.ts

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

src/add/last.ts

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

src/add/map.ts

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

src/add/mapTo.ts

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

src/add/materialize.ts

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

src/add/merge-static.ts

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

src/add/merge.ts

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

src/add/mergeAll.ts

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

src/add/mergeMap.ts

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

src/add/mergeMapTo.ts

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

src/add/multicast.ts

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

src/add/observeOn.ts

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

src/add/partition.ts

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

src/add/publish.ts

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

src/add/publishBehavior.ts

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

src/add/publishReplay.ts

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

src/add/reduce.ts

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

src/add/repeat.ts

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

src/add/retry.ts

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

src/add/retryWhen.ts

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

src/add/sample.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {sample} from '../operator/sample';
+Observable.prototype.sample = sample;

src/add/sampleTime.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {sampleTime} from '../operator/sampleTime';
+Observable.prototype.sampleTime = sampleTime;

src/add/scan.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {scan} from '../operator/scan';
+Observable.prototype.scan = scan;

src/add/share.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {share} from '../operator/share';
+Observable.prototype.share = share;

src/add/single.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {single} from '../operator/single';
+Observable.prototype.single = single;

src/add/skip.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {skip} from '../operator/skip';
+Observable.prototype.skip = skip;

src/add/skipUntil.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {skipUntil} from '../operator/skipUntil';
+Observable.prototype.skipUntil = skipUntil;

src/add/skipWhile.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {skipWhile} from '../operator/skipWhile';
+Observable.prototype.skipWhile = skipWhile;

src/add/startWith.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {startWith} from '../operator/startWith';
+Observable.prototype.startWith = startWith;

src/add/subscribeOn.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {subscribeOn} from '../operator/subscribeOn';
+Observable.prototype.subscribeOn = subscribeOn;

src/add/switch.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {_switch} from '../operator/switch';
+Observable.prototype.switch = _switch;

src/add/switchFirst.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {switchFirst} from '../operator/switchFirst';
+Observable.prototype.switchFirst = switchFirst;

src/add/switchMap.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {switchMap} from '../operator/switchMap';
+Observable.prototype.switchMap = switchMap;

src/add/switchMapFirst.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {switchMapFirst} from '../operator/switchMapFirst';
+Observable.prototype.switchMapFirst = switchMapFirst;

src/add/switchMapTo.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {switchMapTo} from '../operator/switchMapTo';
+Observable.prototype.switchMapTo = switchMapTo;

src/add/take.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {take} from '../operator/take';
+Observable.prototype.take = take;

src/add/takeUntil.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {takeUntil} from '../operator/takeUntil';
+Observable.prototype.takeUntil = takeUntil;

src/add/takeWhile.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {takeWhile} from '../operator/takeWhile';
+Observable.prototype.takeWhile = takeWhile;

src/add/throttle.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {throttle} from '../operator/throttle';
+Observable.prototype.throttle = throttle;

src/add/throttleTime.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {throttleTime} from '../operator/throttleTime';
+Observable.prototype.throttleTime = throttleTime;

src/add/timeout.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {timeout} from '../operator/timeout';
+Observable.prototype.timeout = timeout;

src/add/timeoutWith.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {timeoutWith} from '../operator/timeoutWith';
+Observable.prototype.timeoutWith = timeoutWith;

src/add/toArray.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {toArray} from '../operator/toArray';
+Observable.prototype.toArray = toArray;

src/add/toPromise.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {toPromise} from '../operator/toPromise';
+Observable.prototype.toPromise = toPromise;

src/add/window.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {window} from '../operator/window';
+Observable.prototype.window = window;

src/add/windowCount.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {windowCount} from '../operator/windowCount';
+Observable.prototype.windowCount = windowCount;

src/add/windowTime.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {windowTime} from '../operator/windowTime';
+Observable.prototype.windowTime = windowTime;

src/add/windowToggle.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {windowToggle} from '../operator/windowToggle';
+Observable.prototype.windowToggle = windowToggle;

src/add/windowWhen.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {windowWhen} from '../operator/windowWhen';
+Observable.prototype.windowWhen = windowWhen;

src/add/withLatestFrom.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {withLatestFrom} from '../operator/withLatestFrom';
+Observable.prototype.withLatestFrom = withLatestFrom;

src/add/zip-static.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {zip} from '../operator/zip-static';
+Observable.prototype.zip = zip;

src/add/zip.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {zipProto} from '../operator/zip';
+Observable.prototype.zip = zipProto;

src/add/zipAll.ts

@@ -0,0 +1,3 @@
+import {Observable} from '../Observable';
+import {zipAll} from '../operator/zipAll';
+Observable.prototype.zipAll = zipAll;