diff options
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.js | 18 |
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)); |