aboutsummaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/audit.js
diff options
context:
space:
mode:
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/audit.js')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/audit.js26
1 files changed, 13 insertions, 13 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/audit.js b/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/audit.js
index 493570d291..4c8fc94c69 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/audit.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/audit.js
@@ -1,7 +1,5 @@
-/** PURE_IMPORTS_START tslib,_util_tryCatch,_util_errorObject,_OuterSubscriber,_util_subscribeToResult PURE_IMPORTS_END */
+/** PURE_IMPORTS_START tslib,_OuterSubscriber,_util_subscribeToResult PURE_IMPORTS_END */
import * as tslib_1 from "tslib";
-import { tryCatch } from '../util/tryCatch';
-import { errorObject } from '../util/errorObject';
import { OuterSubscriber } from '../OuterSubscriber';
import { subscribeToResult } from '../util/subscribeToResult';
export function audit(durationSelector) {
@@ -30,18 +28,20 @@ var AuditSubscriber = /*@__PURE__*/ (function (_super) {
this.value = value;
this.hasValue = true;
if (!this.throttled) {
- var duration = tryCatch(this.durationSelector)(value);
- if (duration === errorObject) {
- this.destination.error(errorObject.e);
+ var duration = void 0;
+ try {
+ var durationSelector = this.durationSelector;
+ duration = durationSelector(value);
+ }
+ catch (err) {
+ return this.destination.error(err);
+ }
+ var innerSubscription = subscribeToResult(this, duration);
+ if (!innerSubscription || innerSubscription.closed) {
+ this.clearThrottle();
}
else {
- var innerSubscription = subscribeToResult(this, duration);
- if (!innerSubscription || innerSubscription.closed) {
- this.clearThrottle();
- }
- else {
- this.add(this.throttled = innerSubscription);
- }
+ this.add(this.throttled = innerSubscription);
}
}
};