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%2Fexhaust.js;h=b42928e557867b5b5f411d70f99f063b1d5a2503;hp=8b1c1ef4d99094c78073d6a4dbb32ed6bf6c8beb;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/exhaust.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/exhaust.js index 8b1c1ef4..b42928e5 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/exhaust.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/exhaust.js @@ -13,8 +13,7 @@ var __extends = (this && this.__extends) || (function () { }; })(); Object.defineProperty(exports, "__esModule", { value: true }); -var OuterSubscriber_1 = require("../OuterSubscriber"); -var subscribeToResult_1 = require("../util/subscribeToResult"); +var innerSubscribe_1 = require("../innerSubscribe"); function exhaust() { return function (source) { return source.lift(new SwitchFirstOperator()); }; } @@ -38,7 +37,7 @@ var SwitchFirstSubscriber = (function (_super) { SwitchFirstSubscriber.prototype._next = function (value) { if (!this.hasSubscription) { this.hasSubscription = true; - this.add(subscribeToResult_1.subscribeToResult(this, value)); + this.add(innerSubscribe_1.innerSubscribe(value, new innerSubscribe_1.SimpleInnerSubscriber(this))); } }; SwitchFirstSubscriber.prototype._complete = function () { @@ -47,13 +46,12 @@ var SwitchFirstSubscriber = (function (_super) { this.destination.complete(); } }; - SwitchFirstSubscriber.prototype.notifyComplete = function (innerSub) { - this.remove(innerSub); + SwitchFirstSubscriber.prototype.notifyComplete = function () { this.hasSubscription = false; if (this.hasCompleted) { this.destination.complete(); } }; return SwitchFirstSubscriber; -}(OuterSubscriber_1.OuterSubscriber)); +}(innerSubscribe_1.SimpleOuterSubscriber)); //# sourceMappingURL=exhaust.js.map \ No newline at end of file