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