aboutsummaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/internal/operators/windowWhen.js
diff options
context:
space:
mode:
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/internal/operators/windowWhen.js')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/internal/operators/windowWhen.js18
1 files changed, 9 insertions, 9 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/windowWhen.js b/tools/node_modules/eslint/node_modules/rxjs/internal/operators/windowWhen.js
index 4e184df643..acd73c4c58 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/windowWhen.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/internal/operators/windowWhen.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 windowWhen(closingSelector) {
@@ -81,15 +79,17 @@ var WindowSubscriber = (function (_super) {
}
var window = this.window = new Subject_1.Subject();
this.destination.next(window);
- var closingNotifier = tryCatch_1.tryCatch(this.closingSelector)();
- if (closingNotifier === errorObject_1.errorObject) {
- var err = errorObject_1.errorObject.e;
- this.destination.error(err);
- this.window.error(err);
+ var closingNotifier;
+ try {
+ var closingSelector = this.closingSelector;
+ closingNotifier = closingSelector();
}
- else {
- this.add(this.closingNotification = subscribeToResult_1.subscribeToResult(this, closingNotifier));
+ catch (e) {
+ this.destination.error(e);
+ this.window.error(e);
+ return;
}
+ this.add(this.closingNotification = subscribeToResult_1.subscribeToResult(this, closingNotifier));
};
return WindowSubscriber;
}(OuterSubscriber_1.OuterSubscriber));