aboutsummaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/internal/operators/repeatWhen.js
diff options
context:
space:
mode:
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.js10
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;