Skip to content

Commit

Permalink
feat(operator): add auto-patching operators
Browse files Browse the repository at this point in the history 
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
  • Loading branch information
@jeffbcross @benlesh
jeffbcross authored and benlesh committed Dec 4, 2015
1 parent f12aff5 commit 1ab3508
Show file tree
Hide file tree
Showing 123 changed files with 538 additions and 226 deletions.
204 changes: 102 additions & 102 deletions src/Rx.KitchenSink.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,110 +22,110 @@ export interface KitchenSinkOperators<T> extends CoreOperators<T> {

// statics
/* tslint:disable:no-use-before-declare */
import './operator/combineLatest-static';
import './operator/concat-static';
import './operator/merge-static';
import './observable/defer';
import './observable/empty';
import './observable/forkJoin';
import './observable/from';
import './observable/fromArray';
import './observable/fromEvent';
import './observable/fromEventPattern';
import './observable/fromPromise';
import './observable/fromCallback';
import './observable/interval';
import './observable/never';
import './observable/range';
import './observable/throw';
import './observable/timer';
import './operator/zip-static';
import './add/operator/combineLatest-static';
import './add/operator/concat-static';
import './add/operator/merge-static';
import './add/observable/defer';
import './add/observable/empty';
import './add/observable/forkJoin';
import './add/observable/from';
import './add/observable/fromArray';
import './add/observable/fromEvent';
import './add/observable/fromEventPattern';
import './add/observable/fromPromise';
import './add/observable/fromCallback';
import './add/observable/interval';
import './add/observable/never';
import './add/observable/range';
import './add/observable/throw';
import './add/observable/timer';
import './add/operator/zip-static';

// Operators
import './operator/buffer';
import './operator/bufferCount';
import './operator/bufferTime';
import './operator/bufferToggle';
import './operator/bufferWhen';
import './operator/catch';
import './operator/combineAll';
import './operator/combineLatest';
import './operator/concat';
import './operator/concatAll';
import './operator/concatMap';
import './operator/concatMapTo';
import './operator/count';
import './operator/dematerialize';
import './operator/debounce';
import './operator/debounceTime';
import './operator/defaultIfEmpty';
import './operator/delay';
import './operator/distinctUntilChanged';
import './operator/extended/distinctUntilKeyChanged';
import './operator/do';
import './operator/extended/elementAt';
import './operator/expand';
import './operator/filter';
import './operator/extended/find';
import './operator/extended/findIndex';
import './operator/finally';
import './operator/first';
import './operator/groupBy';
import './operator/ignoreElements';
import './operator/extended/isEmpty';
import './operator/every';
import './operator/last';
import './operator/map';
import './operator/mapTo';
import './operator/materialize';
import './operator/extended/max';
import './operator/merge';
import './operator/mergeAll';
import './operator/mergeMap';
import './operator/mergeMapTo';
import './operator/extended/mergeScan';
import './operator/extended/min';
import './operator/multicast';
import './operator/observeOn';
import './operator/partition';
import './operator/publish';
import './operator/publishBehavior';
import './operator/publishReplay';
import './operator/reduce';
import './operator/repeat';
import './operator/retry';
import './operator/retryWhen';
import './operator/sample';
import './operator/sampleTime';
import './operator/scan';
import './operator/share';
import './operator/single';
import './operator/skip';
import './operator/skipUntil';
import './operator/skipWhile';
import './operator/startWith';
import './operator/subscribeOn';
import './operator/switch';
import './operator/switchMap';
import './operator/switchMapTo';
import './operator/take';
import './operator/takeUntil';
import './operator/takeWhile';
import './operator/throttle';
import './operator/throttleTime';
import './operator/extended/timeInterval';
import './operator/timeout';
import './operator/timeoutWith';
import './operator/toArray';
import './operator/toPromise';
import './operator/window';
import './operator/windowCount';
import './operator/windowTime';
import './operator/windowToggle';
import './operator/windowWhen';
import './operator/withLatestFrom';
import './operator/zip';
import './operator/zipAll';
import './add/operator/buffer';
import './add/operator/bufferCount';
import './add/operator/bufferTime';
import './add/operator/bufferToggle';
import './add/operator/bufferWhen';
import './add/operator/catch';
import './add/operator/combineAll';
import './add/operator/combineLatest';
import './add/operator/concat';
import './add/operator/concatAll';
import './add/operator/concatMap';
import './add/operator/concatMapTo';
import './add/operator/count';
import './add/operator/dematerialize';
import './add/operator/debounce';
import './add/operator/debounceTime';
import './add/operator/defaultIfEmpty';
import './add/operator/delay';
import './add/operator/distinctUntilChanged';
import './add/operator/extended/distinctUntilKeyChanged';
import './add/operator/do';
import './add/operator/extended/elementAt';
import './add/operator/expand';
import './add/operator/filter';
import './add/operator/extended/find';
import './add/operator/extended/findIndex';
import './add/operator/finally';
import './add/operator/first';
import './add/operator/groupBy';
import './add/operator/ignoreElements';
import './add/operator/extended/isEmpty';
import './add/operator/every';
import './add/operator/last';
import './add/operator/map';
import './add/operator/mapTo';
import './add/operator/materialize';
import './add/operator/extended/max';
import './add/operator/merge';
import './add/operator/mergeAll';
import './add/operator/mergeMap';
import './add/operator/mergeMapTo';
import './add/operator/extended/mergeScan';
import './add/operator/extended/min';
import './add/operator/multicast';
import './add/operator/observeOn';
import './add/operator/partition';
import './add/operator/publish';
import './add/operator/publishBehavior';
import './add/operator/publishReplay';
import './add/operator/reduce';
import './add/operator/repeat';
import './add/operator/retry';
import './add/operator/retryWhen';
import './add/operator/sample';
import './add/operator/sampleTime';
import './add/operator/scan';
import './add/operator/share';
import './add/operator/single';
import './add/operator/skip';
import './add/operator/skipUntil';
import './add/operator/skipWhile';
import './add/operator/startWith';
import './add/operator/subscribeOn';
import './add/operator/switch';
import './add/operator/switchMap';
import './add/operator/switchMapTo';
import './add/operator/take';
import './add/operator/takeUntil';
import './add/operator/takeWhile';
import './add/operator/throttle';
import './add/operator/throttleTime';
import './add/operator/extended/timeInterval';
import './add/operator/timeout';
import './add/operator/timeoutWith';
import './add/operator/toArray';
import './add/operator/toPromise';
import './add/operator/window';
import './add/operator/windowCount';
import './add/operator/windowTime';
import './add/operator/windowToggle';
import './add/operator/windowWhen';
import './add/operator/withLatestFrom';
import './add/operator/zip';
import './add/operator/zipAll';

/* tslint:disable:no-unused-variable */
import {Subscription} from './Subscription';
Expand Down
Loading

0 comments on commit 1ab3508

Please sign in to comment.