From 8b7416129448c472882595d61d46aece6f449461 Mon Sep 17 00:00:00 2001 From: Jeff Cross Date: Thu, 3 Dec 2015 12:06:39 -0800 Subject: [PATCH] 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 #860 --- src/operator/add/buffer.ts | 5 +++++ src/operator/add/bufferCount.ts | 5 +++++ src/operator/add/bufferTime.ts | 5 +++++ src/operator/add/bufferToggle.ts | 5 +++++ src/operator/add/bufferWhen.ts | 5 +++++ src/operator/add/catch.ts | 5 +++++ src/operator/add/combineAll.ts | 5 +++++ src/operator/add/combineLatest-static.ts | 5 +++++ src/operator/add/combineLatest.ts | 5 +++++ src/operator/add/concat-static.ts | 5 +++++ src/operator/add/concat.ts | 5 +++++ src/operator/add/concatAll.ts | 5 +++++ src/operator/add/concatMap.ts | 5 +++++ src/operator/add/concatMapTo.ts | 5 +++++ src/operator/add/count.ts | 5 +++++ src/operator/add/debounce.ts | 5 +++++ src/operator/add/debounceTime.ts | 5 +++++ src/operator/add/defaultIfEmpty.ts | 5 +++++ src/operator/add/delay.ts | 5 +++++ src/operator/add/dematerialize.ts | 5 +++++ src/operator/add/distinctUntilChanged.ts | 5 +++++ src/operator/add/do.ts | 5 +++++ src/operator/add/every.ts | 5 +++++ src/operator/add/expand.ts | 5 +++++ src/operator/add/extended/distinctUntilKeyChanged.ts | 5 +++++ src/operator/add/extended/elementAt.ts | 5 +++++ src/operator/add/extended/find.ts | 5 +++++ src/operator/add/extended/findIndex.ts | 5 +++++ src/operator/add/extended/isEmpty.ts | 5 +++++ src/operator/add/extended/max.ts | 5 +++++ src/operator/add/extended/mergeScan.ts | 5 +++++ src/operator/add/extended/min.ts | 5 +++++ src/operator/add/extended/timeInterval.ts | 5 +++++ src/operator/add/filter.ts | 5 +++++ src/operator/add/finally.ts | 5 +++++ src/operator/add/first.ts | 5 +++++ src/operator/add/groupBy.ts | 5 +++++ src/operator/add/ignoreElements.ts | 5 +++++ src/operator/add/last.ts | 5 +++++ src/operator/add/map.ts | 5 +++++ src/operator/add/mapTo.ts | 5 +++++ src/operator/add/materialize.ts | 5 +++++ src/operator/add/merge-static.ts | 5 +++++ src/operator/add/merge.ts | 5 +++++ src/operator/add/mergeAll.ts | 5 +++++ src/operator/add/mergeMap.ts | 6 ++++++ src/operator/add/mergeMapTo.ts | 5 +++++ src/operator/add/multicast.ts | 5 +++++ src/operator/add/observeOn.ts | 5 +++++ src/operator/add/partition.ts | 5 +++++ src/operator/add/publish.ts | 5 +++++ src/operator/add/publishBehavior.ts | 5 +++++ src/operator/add/publishReplay.ts | 5 +++++ src/operator/add/reduce.ts | 5 +++++ src/operator/add/repeat.ts | 5 +++++ src/operator/add/retry.ts | 5 +++++ src/operator/add/retryWhen.ts | 5 +++++ src/operator/add/sample.ts | 5 +++++ src/operator/add/sampleTime.ts | 5 +++++ src/operator/add/scan.ts | 5 +++++ src/operator/add/share.ts | 5 +++++ src/operator/add/single.ts | 5 +++++ src/operator/add/skip.ts | 5 +++++ src/operator/add/skipUntil.ts | 5 +++++ src/operator/add/skipWhile.ts | 5 +++++ src/operator/add/startWith.ts | 5 +++++ src/operator/add/subscribeOn.ts | 5 +++++ src/operator/add/switch.ts | 5 +++++ src/operator/add/switchFirst.ts | 5 +++++ src/operator/add/switchMap.ts | 5 +++++ src/operator/add/switchMapFirst.ts | 5 +++++ src/operator/add/switchMapTo.ts | 5 +++++ src/operator/add/take.ts | 5 +++++ src/operator/add/takeUntil.ts | 5 +++++ src/operator/add/takeWhile.ts | 5 +++++ src/operator/add/throttle.ts | 5 +++++ src/operator/add/throttleTime.ts | 5 +++++ src/operator/add/timeout.ts | 5 +++++ src/operator/add/timeoutWith.ts | 5 +++++ src/operator/add/toArray.ts | 5 +++++ src/operator/add/toPromise.ts | 5 +++++ src/operator/add/window.ts | 5 +++++ src/operator/add/windowCount.ts | 5 +++++ src/operator/add/windowTime.ts | 5 +++++ src/operator/add/windowToggle.ts | 5 +++++ src/operator/add/windowWhen.ts | 5 +++++ src/operator/add/withLatestFrom.ts | 5 +++++ src/operator/add/zip-static.ts | 5 +++++ src/operator/add/zip.ts | 5 +++++ src/operator/add/zipAll.ts | 5 +++++ 90 files changed, 451 insertions(+) create mode 100644 src/operator/add/buffer.ts create mode 100644 src/operator/add/bufferCount.ts create mode 100644 src/operator/add/bufferTime.ts create mode 100644 src/operator/add/bufferToggle.ts create mode 100644 src/operator/add/bufferWhen.ts create mode 100644 src/operator/add/catch.ts create mode 100644 src/operator/add/combineAll.ts create mode 100644 src/operator/add/combineLatest-static.ts create mode 100644 src/operator/add/combineLatest.ts create mode 100644 src/operator/add/concat-static.ts create mode 100644 src/operator/add/concat.ts create mode 100644 src/operator/add/concatAll.ts create mode 100644 src/operator/add/concatMap.ts create mode 100644 src/operator/add/concatMapTo.ts create mode 100644 src/operator/add/count.ts create mode 100644 src/operator/add/debounce.ts create mode 100644 src/operator/add/debounceTime.ts create mode 100644 src/operator/add/defaultIfEmpty.ts create mode 100644 src/operator/add/delay.ts create mode 100644 src/operator/add/dematerialize.ts create mode 100644 src/operator/add/distinctUntilChanged.ts create mode 100644 src/operator/add/do.ts create mode 100644 src/operator/add/every.ts create mode 100644 src/operator/add/expand.ts create mode 100644 src/operator/add/extended/distinctUntilKeyChanged.ts create mode 100644 src/operator/add/extended/elementAt.ts create mode 100644 src/operator/add/extended/find.ts create mode 100644 src/operator/add/extended/findIndex.ts create mode 100644 src/operator/add/extended/isEmpty.ts create mode 100644 src/operator/add/extended/max.ts create mode 100644 src/operator/add/extended/mergeScan.ts create mode 100644 src/operator/add/extended/min.ts create mode 100644 src/operator/add/extended/timeInterval.ts create mode 100644 src/operator/add/filter.ts create mode 100644 src/operator/add/finally.ts create mode 100644 src/operator/add/first.ts create mode 100644 src/operator/add/groupBy.ts create mode 100644 src/operator/add/ignoreElements.ts create mode 100644 src/operator/add/last.ts create mode 100644 src/operator/add/map.ts create mode 100644 src/operator/add/mapTo.ts create mode 100644 src/operator/add/materialize.ts create mode 100644 src/operator/add/merge-static.ts create mode 100644 src/operator/add/merge.ts create mode 100644 src/operator/add/mergeAll.ts create mode 100644 src/operator/add/mergeMap.ts create mode 100644 src/operator/add/mergeMapTo.ts create mode 100644 src/operator/add/multicast.ts create mode 100644 src/operator/add/observeOn.ts create mode 100644 src/operator/add/partition.ts create mode 100644 src/operator/add/publish.ts create mode 100644 src/operator/add/publishBehavior.ts create mode 100644 src/operator/add/publishReplay.ts create mode 100644 src/operator/add/reduce.ts create mode 100644 src/operator/add/repeat.ts create mode 100644 src/operator/add/retry.ts create mode 100644 src/operator/add/retryWhen.ts create mode 100644 src/operator/add/sample.ts create mode 100644 src/operator/add/sampleTime.ts create mode 100644 src/operator/add/scan.ts create mode 100644 src/operator/add/share.ts create mode 100644 src/operator/add/single.ts create mode 100644 src/operator/add/skip.ts create mode 100644 src/operator/add/skipUntil.ts create mode 100644 src/operator/add/skipWhile.ts create mode 100644 src/operator/add/startWith.ts create mode 100644 src/operator/add/subscribeOn.ts create mode 100644 src/operator/add/switch.ts create mode 100644 src/operator/add/switchFirst.ts create mode 100644 src/operator/add/switchMap.ts create mode 100644 src/operator/add/switchMapFirst.ts create mode 100644 src/operator/add/switchMapTo.ts create mode 100644 src/operator/add/take.ts create mode 100644 src/operator/add/takeUntil.ts create mode 100644 src/operator/add/takeWhile.ts create mode 100644 src/operator/add/throttle.ts create mode 100644 src/operator/add/throttleTime.ts create mode 100644 src/operator/add/timeout.ts create mode 100644 src/operator/add/timeoutWith.ts create mode 100644 src/operator/add/toArray.ts create mode 100644 src/operator/add/toPromise.ts create mode 100644 src/operator/add/window.ts create mode 100644 src/operator/add/windowCount.ts create mode 100644 src/operator/add/windowTime.ts create mode 100644 src/operator/add/windowToggle.ts create mode 100644 src/operator/add/windowWhen.ts create mode 100644 src/operator/add/withLatestFrom.ts create mode 100644 src/operator/add/zip-static.ts create mode 100644 src/operator/add/zip.ts create mode 100644 src/operator/add/zipAll.ts diff --git a/src/operator/add/buffer.ts b/src/operator/add/buffer.ts new file mode 100644 index 00000000000..6f2ae8a439e --- /dev/null +++ b/src/operator/add/buffer.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {buffer} from '../buffer'; + + +Observable.prototype.buffer = buffer; diff --git a/src/operator/add/bufferCount.ts b/src/operator/add/bufferCount.ts new file mode 100644 index 00000000000..04137cca6c1 --- /dev/null +++ b/src/operator/add/bufferCount.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {bufferCount} from '../bufferCount'; + + +Observable.prototype.bufferCount = bufferCount; diff --git a/src/operator/add/bufferTime.ts b/src/operator/add/bufferTime.ts new file mode 100644 index 00000000000..116256e5914 --- /dev/null +++ b/src/operator/add/bufferTime.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {bufferTime} from '../bufferTime'; + + +Observable.prototype.bufferTime = bufferTime; diff --git a/src/operator/add/bufferToggle.ts b/src/operator/add/bufferToggle.ts new file mode 100644 index 00000000000..cf1baec4ee7 --- /dev/null +++ b/src/operator/add/bufferToggle.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {bufferToggle} from '../bufferToggle'; + + +Observable.prototype.bufferToggle = bufferToggle; diff --git a/src/operator/add/bufferWhen.ts b/src/operator/add/bufferWhen.ts new file mode 100644 index 00000000000..3141b27345b --- /dev/null +++ b/src/operator/add/bufferWhen.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {bufferWhen} from '../bufferWhen'; + + +Observable.prototype.bufferWhen = bufferWhen; diff --git a/src/operator/add/catch.ts b/src/operator/add/catch.ts new file mode 100644 index 00000000000..e62a1409d1a --- /dev/null +++ b/src/operator/add/catch.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {_catch} from '../catch'; + + +Observable.prototype.catch = _catch; diff --git a/src/operator/add/combineAll.ts b/src/operator/add/combineAll.ts new file mode 100644 index 00000000000..a5f074f7e23 --- /dev/null +++ b/src/operator/add/combineAll.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {combineAll} from '../combineAll'; + + +Observable.prototype.combineAll = combineAll; diff --git a/src/operator/add/combineLatest-static.ts b/src/operator/add/combineLatest-static.ts new file mode 100644 index 00000000000..d67bcb3320f --- /dev/null +++ b/src/operator/add/combineLatest-static.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {combineLatest} from '../combineLatest-static'; + + +Observable.combineLatest = combineLatest; diff --git a/src/operator/add/combineLatest.ts b/src/operator/add/combineLatest.ts new file mode 100644 index 00000000000..587390ebb49 --- /dev/null +++ b/src/operator/add/combineLatest.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {combineLatest} from '../combineLatest'; + + +Observable.prototype.combineLatest = combineLatest; diff --git a/src/operator/add/concat-static.ts b/src/operator/add/concat-static.ts new file mode 100644 index 00000000000..7d8da126375 --- /dev/null +++ b/src/operator/add/concat-static.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {concat} from '../concat-static'; + + +Observable.concat = concat; diff --git a/src/operator/add/concat.ts b/src/operator/add/concat.ts new file mode 100644 index 00000000000..97b4e97671e --- /dev/null +++ b/src/operator/add/concat.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {concat} from '../concat'; + + +Observable.prototype.concat = concat; diff --git a/src/operator/add/concatAll.ts b/src/operator/add/concatAll.ts new file mode 100644 index 00000000000..93075a3fbc6 --- /dev/null +++ b/src/operator/add/concatAll.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {concatAll} from '../concatAll'; + + +Observable.prototype.concatAll = concatAll; diff --git a/src/operator/add/concatMap.ts b/src/operator/add/concatMap.ts new file mode 100644 index 00000000000..3ce2c6c7b1c --- /dev/null +++ b/src/operator/add/concatMap.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {concatMap} from '../concatMap'; + + +Observable.prototype.concatMap = concatMap; diff --git a/src/operator/add/concatMapTo.ts b/src/operator/add/concatMapTo.ts new file mode 100644 index 00000000000..fe37f66387a --- /dev/null +++ b/src/operator/add/concatMapTo.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {concatMapTo} from '../concatMapTo'; + + +Observable.prototype.concatMapTo = concatMapTo; diff --git a/src/operator/add/count.ts b/src/operator/add/count.ts new file mode 100644 index 00000000000..2a0b77416f8 --- /dev/null +++ b/src/operator/add/count.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {count} from '../count'; + + +Observable.prototype.count = count; diff --git a/src/operator/add/debounce.ts b/src/operator/add/debounce.ts new file mode 100644 index 00000000000..dc47317ec7d --- /dev/null +++ b/src/operator/add/debounce.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {debounce} from '../debounce'; + + +Observable.prototype.debounce = debounce; diff --git a/src/operator/add/debounceTime.ts b/src/operator/add/debounceTime.ts new file mode 100644 index 00000000000..a1f18ce0957 --- /dev/null +++ b/src/operator/add/debounceTime.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {debounceTime} from '../debounceTime'; + + +Observable.prototype.debounceTime = debounceTime; diff --git a/src/operator/add/defaultIfEmpty.ts b/src/operator/add/defaultIfEmpty.ts new file mode 100644 index 00000000000..906557901d7 --- /dev/null +++ b/src/operator/add/defaultIfEmpty.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {defaultIfEmpty} from '../defaultIfEmpty'; + + +Observable.prototype.defaultIfEmpty = defaultIfEmpty; diff --git a/src/operator/add/delay.ts b/src/operator/add/delay.ts new file mode 100644 index 00000000000..4d96a5bf0a0 --- /dev/null +++ b/src/operator/add/delay.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {delay} from '../delay'; + + +Observable.prototype.delay = delay; diff --git a/src/operator/add/dematerialize.ts b/src/operator/add/dematerialize.ts new file mode 100644 index 00000000000..759c3150710 --- /dev/null +++ b/src/operator/add/dematerialize.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {dematerialize} from '../dematerialize'; + + +Observable.prototype.dematerialize = dematerialize; diff --git a/src/operator/add/distinctUntilChanged.ts b/src/operator/add/distinctUntilChanged.ts new file mode 100644 index 00000000000..cc0c94661a8 --- /dev/null +++ b/src/operator/add/distinctUntilChanged.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {distinctUntilChanged} from '../distinctUntilChanged'; + + +Observable.prototype.distinctUntilChanged = distinctUntilChanged; diff --git a/src/operator/add/do.ts b/src/operator/add/do.ts new file mode 100644 index 00000000000..6dee05ce5d3 --- /dev/null +++ b/src/operator/add/do.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {_do} from '../do'; + + +Observable.prototype.do = _do; diff --git a/src/operator/add/every.ts b/src/operator/add/every.ts new file mode 100644 index 00000000000..d96a117427a --- /dev/null +++ b/src/operator/add/every.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {every} from '../every'; + + +Observable.prototype.every = every; diff --git a/src/operator/add/expand.ts b/src/operator/add/expand.ts new file mode 100644 index 00000000000..8d663293ba0 --- /dev/null +++ b/src/operator/add/expand.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {expand} from '../expand'; + + +Observable.prototype.expand = expand; diff --git a/src/operator/add/extended/distinctUntilKeyChanged.ts b/src/operator/add/extended/distinctUntilKeyChanged.ts new file mode 100644 index 00000000000..804ffdec9dc --- /dev/null +++ b/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 = (>Observable.prototype); +observableProto.distinctUntilKeyChanged = distinctUntilKeyChanged; diff --git a/src/operator/add/extended/elementAt.ts b/src/operator/add/extended/elementAt.ts new file mode 100644 index 00000000000..e23bda1c7a1 --- /dev/null +++ b/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 = (>Observable.prototype); +observableProto.elementAt = elementAt; diff --git a/src/operator/add/extended/find.ts b/src/operator/add/extended/find.ts new file mode 100644 index 00000000000..fe4c35ac0bb --- /dev/null +++ b/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 = (>Observable.prototype); +observableProto.find = find; diff --git a/src/operator/add/extended/findIndex.ts b/src/operator/add/extended/findIndex.ts new file mode 100644 index 00000000000..530e5a6dbfa --- /dev/null +++ b/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 = (>Observable.prototype); +observableProto.findIndex = findIndex; diff --git a/src/operator/add/extended/isEmpty.ts b/src/operator/add/extended/isEmpty.ts new file mode 100644 index 00000000000..9e1eefbe387 --- /dev/null +++ b/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 = (>Observable.prototype); +observableProto.isEmpty = isEmpty; diff --git a/src/operator/add/extended/max.ts b/src/operator/add/extended/max.ts new file mode 100644 index 00000000000..fcf8d77089c --- /dev/null +++ b/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 = (>Observable.prototype); +observableProto.max = max; diff --git a/src/operator/add/extended/mergeScan.ts b/src/operator/add/extended/mergeScan.ts new file mode 100644 index 00000000000..7f302ab57a7 --- /dev/null +++ b/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 = (>Observable.prototype); +observableProto.mergeScan = mergeScan; diff --git a/src/operator/add/extended/min.ts b/src/operator/add/extended/min.ts new file mode 100644 index 00000000000..ba949fbf7ea --- /dev/null +++ b/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 = (>Observable.prototype); +observableProto.min = min; diff --git a/src/operator/add/extended/timeInterval.ts b/src/operator/add/extended/timeInterval.ts new file mode 100644 index 00000000000..dd7d7a2e6ba --- /dev/null +++ b/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 = (>Observable.prototype); +observableProto.timeInterval = timeInterval; diff --git a/src/operator/add/filter.ts b/src/operator/add/filter.ts new file mode 100644 index 00000000000..1f841666cee --- /dev/null +++ b/src/operator/add/filter.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {filter} from '../filter'; + + +Observable.prototype.filter = filter; diff --git a/src/operator/add/finally.ts b/src/operator/add/finally.ts new file mode 100644 index 00000000000..f2a24204cc6 --- /dev/null +++ b/src/operator/add/finally.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {_finally} from '../finally'; + + +Observable.prototype.finally = _finally; diff --git a/src/operator/add/first.ts b/src/operator/add/first.ts new file mode 100644 index 00000000000..27af7f2b9d9 --- /dev/null +++ b/src/operator/add/first.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {first} from '../first'; + + +Observable.prototype.first = first; diff --git a/src/operator/add/groupBy.ts b/src/operator/add/groupBy.ts new file mode 100644 index 00000000000..7105c4e202b --- /dev/null +++ b/src/operator/add/groupBy.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {groupBy} from '../groupBy'; + + +Observable.prototype.groupBy = groupBy; diff --git a/src/operator/add/ignoreElements.ts b/src/operator/add/ignoreElements.ts new file mode 100644 index 00000000000..9b2bce927fe --- /dev/null +++ b/src/operator/add/ignoreElements.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {ignoreElements} from '../ignoreElements'; + + +Observable.prototype.ignoreElements = ignoreElements; diff --git a/src/operator/add/last.ts b/src/operator/add/last.ts new file mode 100644 index 00000000000..33d6205c6ac --- /dev/null +++ b/src/operator/add/last.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {last} from '../last'; + + +Observable.prototype.last = last; diff --git a/src/operator/add/map.ts b/src/operator/add/map.ts new file mode 100644 index 00000000000..14595d0a125 --- /dev/null +++ b/src/operator/add/map.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {map} from '../map'; + + +Observable.prototype.map = map; diff --git a/src/operator/add/mapTo.ts b/src/operator/add/mapTo.ts new file mode 100644 index 00000000000..72980f1f356 --- /dev/null +++ b/src/operator/add/mapTo.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {mapTo} from '../mapTo'; + + +Observable.prototype.mapTo = mapTo; diff --git a/src/operator/add/materialize.ts b/src/operator/add/materialize.ts new file mode 100644 index 00000000000..a17af09a3b6 --- /dev/null +++ b/src/operator/add/materialize.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {materialize} from '../materialize'; + + +Observable.prototype.materialize = materialize; diff --git a/src/operator/add/merge-static.ts b/src/operator/add/merge-static.ts new file mode 100644 index 00000000000..25ecb092a64 --- /dev/null +++ b/src/operator/add/merge-static.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {merge} from '../merge-static'; + + +Observable.merge = merge; diff --git a/src/operator/add/merge.ts b/src/operator/add/merge.ts new file mode 100644 index 00000000000..ea7f99f57ae --- /dev/null +++ b/src/operator/add/merge.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {merge} from '../merge'; + + +Observable.prototype.merge = merge; diff --git a/src/operator/add/mergeAll.ts b/src/operator/add/mergeAll.ts new file mode 100644 index 00000000000..9e38d693d88 --- /dev/null +++ b/src/operator/add/mergeAll.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {mergeAll} from '../mergeAll'; + + +Observable.prototype.mergeAll = mergeAll; diff --git a/src/operator/add/mergeMap.ts b/src/operator/add/mergeMap.ts new file mode 100644 index 00000000000..40718769e22 --- /dev/null +++ b/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; diff --git a/src/operator/add/mergeMapTo.ts b/src/operator/add/mergeMapTo.ts new file mode 100644 index 00000000000..7c3640a09ac --- /dev/null +++ b/src/operator/add/mergeMapTo.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {mergeMapTo} from '../mergeMapTo'; + + +Observable.prototype.mergeMapTo = mergeMapTo; diff --git a/src/operator/add/multicast.ts b/src/operator/add/multicast.ts new file mode 100644 index 00000000000..95632b9f7e8 --- /dev/null +++ b/src/operator/add/multicast.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {multicast} from '../multicast'; + + +Observable.prototype.multicast = multicast; diff --git a/src/operator/add/observeOn.ts b/src/operator/add/observeOn.ts new file mode 100644 index 00000000000..ede96b64d5e --- /dev/null +++ b/src/operator/add/observeOn.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {observeOn} from '../observeOn'; + + +Observable.prototype.observeOn = observeOn; diff --git a/src/operator/add/partition.ts b/src/operator/add/partition.ts new file mode 100644 index 00000000000..cf9ca7ed916 --- /dev/null +++ b/src/operator/add/partition.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {partition} from '../partition'; + + +Observable.prototype.partition = partition; diff --git a/src/operator/add/publish.ts b/src/operator/add/publish.ts new file mode 100644 index 00000000000..b3f14f73c5e --- /dev/null +++ b/src/operator/add/publish.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {publish} from '../publish'; + + +Observable.prototype.publish = publish; diff --git a/src/operator/add/publishBehavior.ts b/src/operator/add/publishBehavior.ts new file mode 100644 index 00000000000..69b3a59a328 --- /dev/null +++ b/src/operator/add/publishBehavior.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {publishBehavior} from '../publishBehavior'; + + +Observable.prototype.publishBehavior = publishBehavior; diff --git a/src/operator/add/publishReplay.ts b/src/operator/add/publishReplay.ts new file mode 100644 index 00000000000..805202434bb --- /dev/null +++ b/src/operator/add/publishReplay.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {publishReplay} from '../publishReplay'; + + +Observable.prototype.publishReplay = publishReplay; diff --git a/src/operator/add/reduce.ts b/src/operator/add/reduce.ts new file mode 100644 index 00000000000..715854f4139 --- /dev/null +++ b/src/operator/add/reduce.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {reduce} from '../reduce'; + + +Observable.prototype.reduce = reduce; diff --git a/src/operator/add/repeat.ts b/src/operator/add/repeat.ts new file mode 100644 index 00000000000..c0eb31517a9 --- /dev/null +++ b/src/operator/add/repeat.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {repeat} from '../repeat'; + + +Observable.prototype.repeat = repeat; diff --git a/src/operator/add/retry.ts b/src/operator/add/retry.ts new file mode 100644 index 00000000000..cf3b5185cc9 --- /dev/null +++ b/src/operator/add/retry.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {retry} from '../retry'; + + +Observable.prototype.retry = retry; diff --git a/src/operator/add/retryWhen.ts b/src/operator/add/retryWhen.ts new file mode 100644 index 00000000000..cd0cb5b99a6 --- /dev/null +++ b/src/operator/add/retryWhen.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {retryWhen} from '../retryWhen'; + + +Observable.prototype.retryWhen = retryWhen; diff --git a/src/operator/add/sample.ts b/src/operator/add/sample.ts new file mode 100644 index 00000000000..9fbf9d98d3e --- /dev/null +++ b/src/operator/add/sample.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {sample} from '../sample'; + + +Observable.prototype.sample = sample; diff --git a/src/operator/add/sampleTime.ts b/src/operator/add/sampleTime.ts new file mode 100644 index 00000000000..481b497feb7 --- /dev/null +++ b/src/operator/add/sampleTime.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {sampleTime} from '../sampleTime'; + + +Observable.prototype.sampleTime = sampleTime; diff --git a/src/operator/add/scan.ts b/src/operator/add/scan.ts new file mode 100644 index 00000000000..e73c6371b14 --- /dev/null +++ b/src/operator/add/scan.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {scan} from '../scan'; + + +Observable.prototype.scan = scan; diff --git a/src/operator/add/share.ts b/src/operator/add/share.ts new file mode 100644 index 00000000000..84901659bce --- /dev/null +++ b/src/operator/add/share.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {share} from '../share'; + + +Observable.prototype.share = share; diff --git a/src/operator/add/single.ts b/src/operator/add/single.ts new file mode 100644 index 00000000000..9e231655065 --- /dev/null +++ b/src/operator/add/single.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {single} from '../single'; + + +Observable.prototype.single = single; diff --git a/src/operator/add/skip.ts b/src/operator/add/skip.ts new file mode 100644 index 00000000000..ae5ccb659c7 --- /dev/null +++ b/src/operator/add/skip.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {skip} from '../skip'; + + +Observable.prototype.skip = skip; diff --git a/src/operator/add/skipUntil.ts b/src/operator/add/skipUntil.ts new file mode 100644 index 00000000000..3bf39e4d53a --- /dev/null +++ b/src/operator/add/skipUntil.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {skipUntil} from '../skipUntil'; + + +Observable.prototype.skipUntil = skipUntil; diff --git a/src/operator/add/skipWhile.ts b/src/operator/add/skipWhile.ts new file mode 100644 index 00000000000..c70764496d6 --- /dev/null +++ b/src/operator/add/skipWhile.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {skipWhile} from '../skipWhile'; + + +Observable.prototype.skipWhile = skipWhile; diff --git a/src/operator/add/startWith.ts b/src/operator/add/startWith.ts new file mode 100644 index 00000000000..efa2782ab09 --- /dev/null +++ b/src/operator/add/startWith.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {startWith} from '../startWith'; + + +Observable.prototype.startWith = startWith; diff --git a/src/operator/add/subscribeOn.ts b/src/operator/add/subscribeOn.ts new file mode 100644 index 00000000000..28fdfeae6e1 --- /dev/null +++ b/src/operator/add/subscribeOn.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {subscribeOn} from '../subscribeOn'; + + +Observable.prototype.subscribeOn = subscribeOn; diff --git a/src/operator/add/switch.ts b/src/operator/add/switch.ts new file mode 100644 index 00000000000..344084afb46 --- /dev/null +++ b/src/operator/add/switch.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {_switch} from '../switch'; + + +Observable.prototype.switch = _switch; diff --git a/src/operator/add/switchFirst.ts b/src/operator/add/switchFirst.ts new file mode 100644 index 00000000000..b0a78c58140 --- /dev/null +++ b/src/operator/add/switchFirst.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {switchFirst} from '../switchFirst'; + + +Observable.prototype.switchFirst = switchFirst; diff --git a/src/operator/add/switchMap.ts b/src/operator/add/switchMap.ts new file mode 100644 index 00000000000..8aa208501c6 --- /dev/null +++ b/src/operator/add/switchMap.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {switchMap} from '../switchMap'; + + +Observable.prototype.switchMap = switchMap; diff --git a/src/operator/add/switchMapFirst.ts b/src/operator/add/switchMapFirst.ts new file mode 100644 index 00000000000..06b38939c3f --- /dev/null +++ b/src/operator/add/switchMapFirst.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {switchMapFirst} from '../switchMapFirst'; + + +Observable.prototype.switchMapFirst = switchMapFirst; diff --git a/src/operator/add/switchMapTo.ts b/src/operator/add/switchMapTo.ts new file mode 100644 index 00000000000..8e098cc2b29 --- /dev/null +++ b/src/operator/add/switchMapTo.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {switchMapTo} from '../switchMapTo'; + + +Observable.prototype.switchMapTo = switchMapTo; diff --git a/src/operator/add/take.ts b/src/operator/add/take.ts new file mode 100644 index 00000000000..2a396f9f2b9 --- /dev/null +++ b/src/operator/add/take.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {take} from '../take'; + + +Observable.prototype.take = take; diff --git a/src/operator/add/takeUntil.ts b/src/operator/add/takeUntil.ts new file mode 100644 index 00000000000..0c224b20e34 --- /dev/null +++ b/src/operator/add/takeUntil.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {takeUntil} from '../takeUntil'; + + +Observable.prototype.takeUntil = takeUntil; diff --git a/src/operator/add/takeWhile.ts b/src/operator/add/takeWhile.ts new file mode 100644 index 00000000000..1e68e6e694e --- /dev/null +++ b/src/operator/add/takeWhile.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {takeWhile} from '../takeWhile'; + + +Observable.prototype.takeWhile = takeWhile; diff --git a/src/operator/add/throttle.ts b/src/operator/add/throttle.ts new file mode 100644 index 00000000000..f9b2c478d21 --- /dev/null +++ b/src/operator/add/throttle.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {throttle} from '../throttle'; + + +Observable.prototype.throttle = throttle; diff --git a/src/operator/add/throttleTime.ts b/src/operator/add/throttleTime.ts new file mode 100644 index 00000000000..f36e3d2488a --- /dev/null +++ b/src/operator/add/throttleTime.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {throttleTime} from '../throttleTime'; + + +Observable.prototype.throttleTime = throttleTime; diff --git a/src/operator/add/timeout.ts b/src/operator/add/timeout.ts new file mode 100644 index 00000000000..186948fccc8 --- /dev/null +++ b/src/operator/add/timeout.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {timeout} from '../timeout'; + + +Observable.prototype.timeout = timeout; diff --git a/src/operator/add/timeoutWith.ts b/src/operator/add/timeoutWith.ts new file mode 100644 index 00000000000..3d23f1d639d --- /dev/null +++ b/src/operator/add/timeoutWith.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {timeoutWith} from '../timeoutWith'; + + +Observable.prototype.timeoutWith = timeoutWith; diff --git a/src/operator/add/toArray.ts b/src/operator/add/toArray.ts new file mode 100644 index 00000000000..0fb24a4a4a7 --- /dev/null +++ b/src/operator/add/toArray.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {toArray} from '../toArray'; + + +Observable.prototype.toArray = toArray; diff --git a/src/operator/add/toPromise.ts b/src/operator/add/toPromise.ts new file mode 100644 index 00000000000..49be1175c93 --- /dev/null +++ b/src/operator/add/toPromise.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {toPromise} from '../toPromise'; + + +Observable.prototype.toPromise = toPromise; diff --git a/src/operator/add/window.ts b/src/operator/add/window.ts new file mode 100644 index 00000000000..90c90d22094 --- /dev/null +++ b/src/operator/add/window.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {window} from '../window'; + + +Observable.prototype.window = window; diff --git a/src/operator/add/windowCount.ts b/src/operator/add/windowCount.ts new file mode 100644 index 00000000000..0be6398afbc --- /dev/null +++ b/src/operator/add/windowCount.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {windowCount} from '../windowCount'; + + +Observable.prototype.windowCount = windowCount; diff --git a/src/operator/add/windowTime.ts b/src/operator/add/windowTime.ts new file mode 100644 index 00000000000..019a4762bfc --- /dev/null +++ b/src/operator/add/windowTime.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {windowTime} from '../windowTime'; + + +Observable.prototype.windowTime = windowTime; diff --git a/src/operator/add/windowToggle.ts b/src/operator/add/windowToggle.ts new file mode 100644 index 00000000000..975f7eac86b --- /dev/null +++ b/src/operator/add/windowToggle.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {windowToggle} from '../windowToggle'; + + +Observable.prototype.windowToggle = windowToggle; diff --git a/src/operator/add/windowWhen.ts b/src/operator/add/windowWhen.ts new file mode 100644 index 00000000000..496e7da6d54 --- /dev/null +++ b/src/operator/add/windowWhen.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {windowWhen} from '../windowWhen'; + + +Observable.prototype.windowWhen = windowWhen; diff --git a/src/operator/add/withLatestFrom.ts b/src/operator/add/withLatestFrom.ts new file mode 100644 index 00000000000..cdfbbc856d9 --- /dev/null +++ b/src/operator/add/withLatestFrom.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {withLatestFrom} from '../withLatestFrom'; + + +Observable.prototype.withLatestFrom = withLatestFrom; diff --git a/src/operator/add/zip-static.ts b/src/operator/add/zip-static.ts new file mode 100644 index 00000000000..6e197c8b819 --- /dev/null +++ b/src/operator/add/zip-static.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {zip} from '../zip-static'; + + +Observable.zip = zip; diff --git a/src/operator/add/zip.ts b/src/operator/add/zip.ts new file mode 100644 index 00000000000..1b86b2b62cc --- /dev/null +++ b/src/operator/add/zip.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {zipProto} from '../zip'; + + +Observable.prototype.zip = zipProto; diff --git a/src/operator/add/zipAll.ts b/src/operator/add/zipAll.ts new file mode 100644 index 00000000000..fc067480603 --- /dev/null +++ b/src/operator/add/zipAll.ts @@ -0,0 +1,5 @@ +import {Observable} from '../../Observable'; +import {zipAll} from '../zipAll'; + + +Observable.prototype.zipAll = zipAll;