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%2FonErrorResumeNext.js;h=5d5f8b61d85905b497c118c85490223f98af0329;hp=b4dfcbf19cb523575e5a160fc22ce354178765ac;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/onErrorResumeNext.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/onErrorResumeNext.js index b4dfcbf1..5d5f8b61 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/onErrorResumeNext.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/onErrorResumeNext.js @@ -15,9 +15,7 @@ var __extends = (this && this.__extends) || (function () { Object.defineProperty(exports, "__esModule", { value: true }); var from_1 = require("../observable/from"); var isArray_1 = require("../util/isArray"); -var OuterSubscriber_1 = require("../OuterSubscriber"); -var InnerSubscriber_1 = require("../InnerSubscriber"); -var subscribeToResult_1 = require("../util/subscribeToResult"); +var innerSubscribe_1 = require("../innerSubscribe"); function onErrorResumeNext() { var nextSources = []; for (var _i = 0; _i < arguments.length; _i++) { @@ -34,12 +32,12 @@ function onErrorResumeNextStatic() { for (var _i = 0; _i < arguments.length; _i++) { nextSources[_i] = arguments[_i]; } - var source = null; + var source = undefined; if (nextSources.length === 1 && isArray_1.isArray(nextSources[0])) { nextSources = nextSources[0]; } source = nextSources.shift(); - return from_1.from(source, null).lift(new OnErrorResumeNextOperator(nextSources)); + return from_1.from(source).lift(new OnErrorResumeNextOperator(nextSources)); } exports.onErrorResumeNextStatic = onErrorResumeNextStatic; var OnErrorResumeNextOperator = (function () { @@ -59,10 +57,10 @@ var OnErrorResumeNextSubscriber = (function (_super) { _this.nextSources = nextSources; return _this; } - OnErrorResumeNextSubscriber.prototype.notifyError = function (error, innerSub) { + OnErrorResumeNextSubscriber.prototype.notifyError = function () { this.subscribeToNextSource(); }; - OnErrorResumeNextSubscriber.prototype.notifyComplete = function (innerSub) { + OnErrorResumeNextSubscriber.prototype.notifyComplete = function () { this.subscribeToNextSource(); }; OnErrorResumeNextSubscriber.prototype._error = function (err) { @@ -76,10 +74,10 @@ var OnErrorResumeNextSubscriber = (function (_super) { OnErrorResumeNextSubscriber.prototype.subscribeToNextSource = function () { var next = this.nextSources.shift(); if (!!next) { - var innerSubscriber = new InnerSubscriber_1.InnerSubscriber(this, undefined, undefined); + var innerSubscriber = new innerSubscribe_1.SimpleInnerSubscriber(this); var destination = this.destination; destination.add(innerSubscriber); - var innerSubscription = subscribeToResult_1.subscribeToResult(this, next, undefined, undefined, innerSubscriber); + var innerSubscription = innerSubscribe_1.innerSubscribe(next, innerSubscriber); if (innerSubscription !== innerSubscriber) { destination.add(innerSubscription); } @@ -89,5 +87,5 @@ var OnErrorResumeNextSubscriber = (function (_super) { } }; return OnErrorResumeNextSubscriber; -}(OuterSubscriber_1.OuterSubscriber)); +}(innerSubscribe_1.SimpleOuterSubscriber)); //# sourceMappingURL=onErrorResumeNext.js.map \ No newline at end of file