diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/internal/operators/repeatWhen.js')
-rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/internal/operators/repeatWhen.js | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/repeatWhen.js b/tools/node_modules/eslint/node_modules/rxjs/internal/operators/repeatWhen.js index ce72abc7d6..1c1d12ed80 100644 --- a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/repeatWhen.js +++ b/tools/node_modules/eslint/node_modules/rxjs/internal/operators/repeatWhen.js @@ -14,8 +14,6 @@ var __extends = (this && this.__extends) || (function () { })(); Object.defineProperty(exports, "__esModule", { value: true }); var Subject_1 = require("../Subject"); -var tryCatch_1 = require("../util/tryCatch"); -var errorObject_1 = require("../util/errorObject"); var OuterSubscriber_1 = require("../OuterSubscriber"); var subscribeToResult_1 = require("../util/subscribeToResult"); function repeatWhen(notifier) { @@ -83,8 +81,12 @@ var RepeatWhenSubscriber = (function (_super) { }; RepeatWhenSubscriber.prototype.subscribeToRetries = function () { this.notifications = new Subject_1.Subject(); - var retries = tryCatch_1.tryCatch(this.notifier)(this.notifications); - if (retries === errorObject_1.errorObject) { + var retries; + try { + var notifier = this.notifier; + retries = notifier(this.notifications); + } + catch (e) { return _super.prototype.complete.call(this); } this.retries = retries; |