diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/bufferWhen.js')
-rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/bufferWhen.js | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/bufferWhen.js b/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/bufferWhen.js index fb82a6b908..7a0872adda 100644 --- a/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/bufferWhen.js +++ b/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/bufferWhen.js @@ -1,8 +1,6 @@ -/** PURE_IMPORTS_START tslib,_Subscription,_util_tryCatch,_util_errorObject,_OuterSubscriber,_util_subscribeToResult PURE_IMPORTS_END */ +/** PURE_IMPORTS_START tslib,_Subscription,_OuterSubscriber,_util_subscribeToResult PURE_IMPORTS_END */ import * as tslib_1 from "tslib"; import { Subscription } from '../Subscription'; -import { tryCatch } from '../util/tryCatch'; -import { errorObject } from '../util/errorObject'; import { OuterSubscriber } from '../OuterSubscriber'; import { subscribeToResult } from '../util/subscribeToResult'; export function bufferWhen(closingSelector) { @@ -64,18 +62,20 @@ var BufferWhenSubscriber = /*@__PURE__*/ (function (_super) { this.destination.next(buffer); } this.buffer = []; - var closingNotifier = tryCatch(this.closingSelector)(); - if (closingNotifier === errorObject) { - this.error(errorObject.e); + var closingNotifier; + try { + var closingSelector = this.closingSelector; + closingNotifier = closingSelector(); } - else { - closingSubscription = new Subscription(); - this.closingSubscription = closingSubscription; - this.add(closingSubscription); - this.subscribing = true; - closingSubscription.add(subscribeToResult(this, closingNotifier)); - this.subscribing = false; + catch (err) { + return this.error(err); } + closingSubscription = new Subscription(); + this.closingSubscription = closingSubscription; + this.add(closingSubscription); + this.subscribing = true; + closingSubscription.add(subscribeToResult(this, closingNotifier)); + this.subscribing = false; }; return BufferWhenSubscriber; }(OuterSubscriber)); |