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