diff options
Diffstat (limited to 'node_modules/rxjs/dist/cjs/internal/operators/exhaustMap.js')
| -rw-r--r-- | node_modules/rxjs/dist/cjs/internal/operators/exhaustMap.js | 33 |
1 files changed, 0 insertions, 33 deletions
diff --git a/node_modules/rxjs/dist/cjs/internal/operators/exhaustMap.js b/node_modules/rxjs/dist/cjs/internal/operators/exhaustMap.js deleted file mode 100644 index 1e1bafa..0000000 --- a/node_modules/rxjs/dist/cjs/internal/operators/exhaustMap.js +++ /dev/null @@ -1,33 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.exhaustMap = void 0; -var map_1 = require("./map"); -var innerFrom_1 = require("../observable/innerFrom"); -var lift_1 = require("../util/lift"); -var OperatorSubscriber_1 = require("./OperatorSubscriber"); -function exhaustMap(project, resultSelector) { - if (resultSelector) { - return function (source) { - return source.pipe(exhaustMap(function (a, i) { return innerFrom_1.innerFrom(project(a, i)).pipe(map_1.map(function (b, ii) { return resultSelector(a, b, i, ii); })); })); - }; - } - return lift_1.operate(function (source, subscriber) { - var index = 0; - var innerSub = null; - var isComplete = false; - source.subscribe(OperatorSubscriber_1.createOperatorSubscriber(subscriber, function (outerValue) { - if (!innerSub) { - innerSub = OperatorSubscriber_1.createOperatorSubscriber(subscriber, undefined, function () { - innerSub = null; - isComplete && subscriber.complete(); - }); - innerFrom_1.innerFrom(project(outerValue, index++)).subscribe(innerSub); - } - }, function () { - isComplete = true; - !innerSub && subscriber.complete(); - })); - }); -} -exports.exhaustMap = exhaustMap; -//# sourceMappingURL=exhaustMap.js.map
\ No newline at end of file |
