diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/exhaustMap.js')
-rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/exhaustMap.js | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/exhaustMap.js b/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/exhaustMap.js index ee655e197a..c018d6840c 100644 --- a/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/exhaustMap.js +++ b/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/exhaustMap.js @@ -10,17 +10,17 @@ export function exhaustMap(project, resultSelector) { return function (source) { return source.pipe(exhaustMap(function (a, i) { return from(project(a, i)).pipe(map(function (b, ii) { return resultSelector(a, b, i, ii); })); })); }; } return function (source) { - return source.lift(new ExhauseMapOperator(project)); + return source.lift(new ExhaustMapOperator(project)); }; } -var ExhauseMapOperator = /*@__PURE__*/ (function () { - function ExhauseMapOperator(project) { +var ExhaustMapOperator = /*@__PURE__*/ (function () { + function ExhaustMapOperator(project) { this.project = project; } - ExhauseMapOperator.prototype.call = function (subscriber, source) { + ExhaustMapOperator.prototype.call = function (subscriber, source) { return source.subscribe(new ExhaustMapSubscriber(subscriber, this.project)); }; - return ExhauseMapOperator; + return ExhaustMapOperator; }()); var ExhaustMapSubscriber = /*@__PURE__*/ (function (_super) { tslib_1.__extends(ExhaustMapSubscriber, _super); |