X-Git-Url: https://git.josue.xyz/?p=dotfiles%2F.git;a=blobdiff_plain;f=.config%2Fcoc%2Fextensions%2Fnode_modules%2Fcoc-prettier%2Fnode_modules%2Frxjs%2Finternal%2Foperators%2FswitchMap.js;h=c9fbdb4a25b1e8e91e932f5c41b56dc5ea1b2d75;hp=f522e8c43296709dfa6cc67ffc8376d80bd530db;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/switchMap.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/switchMap.js index f522e8c4..c9fbdb4a 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/switchMap.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/switchMap.js @@ -13,11 +13,9 @@ var __extends = (this && this.__extends) || (function () { }; })(); Object.defineProperty(exports, "__esModule", { value: true }); -var OuterSubscriber_1 = require("../OuterSubscriber"); -var InnerSubscriber_1 = require("../InnerSubscriber"); -var subscribeToResult_1 = require("../util/subscribeToResult"); var map_1 = require("./map"); var from_1 = require("../observable/from"); +var innerSubscribe_1 = require("../innerSubscribe"); function switchMap(project, resultSelector) { if (typeof resultSelector === 'function') { return function (source) { return source.pipe(switchMap(function (a, i) { return from_1.from(project(a, i)).pipe(map_1.map(function (b, ii) { return resultSelector(a, b, i, ii); })); })); }; @@ -52,17 +50,17 @@ var SwitchMapSubscriber = (function (_super) { this.destination.error(error); return; } - this._innerSub(result, value, index); + this._innerSub(result); }; - SwitchMapSubscriber.prototype._innerSub = function (result, value, index) { + SwitchMapSubscriber.prototype._innerSub = function (result) { var innerSubscription = this.innerSubscription; if (innerSubscription) { innerSubscription.unsubscribe(); } - var innerSubscriber = new InnerSubscriber_1.InnerSubscriber(this, value, index); + var innerSubscriber = new innerSubscribe_1.SimpleInnerSubscriber(this); var destination = this.destination; destination.add(innerSubscriber); - this.innerSubscription = subscribeToResult_1.subscribeToResult(this, result, undefined, undefined, innerSubscriber); + this.innerSubscription = innerSubscribe_1.innerSubscribe(result, innerSubscriber); if (this.innerSubscription !== innerSubscriber) { destination.add(this.innerSubscription); } @@ -75,19 +73,17 @@ var SwitchMapSubscriber = (function (_super) { this.unsubscribe(); }; SwitchMapSubscriber.prototype._unsubscribe = function () { - this.innerSubscription = null; + this.innerSubscription = undefined; }; - SwitchMapSubscriber.prototype.notifyComplete = function (innerSub) { - var destination = this.destination; - destination.remove(innerSub); - this.innerSubscription = null; + SwitchMapSubscriber.prototype.notifyComplete = function () { + this.innerSubscription = undefined; if (this.isStopped) { _super.prototype._complete.call(this); } }; - SwitchMapSubscriber.prototype.notifyNext = function (outerValue, innerValue, outerIndex, innerIndex, innerSub) { + SwitchMapSubscriber.prototype.notifyNext = function (innerValue) { this.destination.next(innerValue); }; return SwitchMapSubscriber; -}(OuterSubscriber_1.OuterSubscriber)); +}(innerSubscribe_1.SimpleOuterSubscriber)); //# sourceMappingURL=switchMap.js.map \ No newline at end of file