1 files changed, 14 insertions, 11 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/audit.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/audit.ts
index 52df9fdb3b..04992c0fd9 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/audit.ts
+++ b/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/audit.ts
@@ -4,8 +4,6 @@ import { Observable } from '../Observable';
 import { Subscription } from '../Subscription';
 import { MonoTypeOperatorFunction, SubscribableOrPromise, TeardownLogic } from '../types';
 
-import { tryCatch } from '../util/tryCatch';
-import { errorObject } from '../util/errorObject';
 import { OuterSubscriber } from '../OuterSubscriber';
 import { subscribeToResult } from '../util/subscribeToResult';
 
@@ -34,6 +32,9 @@ import { subscribeToResult } from '../util/subscribeToResult';
  *
  * Emit clicks at a rate of at most one click per second
  * ```javascript
+ * import { fromEvent, interval } from 'rxjs';
+ * import { audit } from 'rxjs/operators'
+ *
  * const clicks = fromEvent(document, 'click');
  * const result = clicks.pipe(audit(ev => interval(1000)));
  * result.subscribe(x => console.log(x));
@@ -87,16 +88,18 @@ class AuditSubscriber<T, R> extends OuterSubscriber<T, R> {
     this.value = value;
     this.hasValue = true;
     if (!this.throttled) {
-      const duration = tryCatch(this.durationSelector)(value);
-      if (duration === errorObject) {
-        this.destination.error(errorObject.e);
+      let duration;
+      try {
+        const { durationSelector } = this;
+        duration = durationSelector(value);
+      } catch (err) {
+        return this.destination.error(err);
+      }
+      const innerSubscription = subscribeToResult(this, duration);
+      if (!innerSubscription || innerSubscription.closed) {
+        this.clearThrottle();
       } else {
-        const innerSubscription = subscribeToResult(this, duration);
-        if (!innerSubscription || innerSubscription.closed) {
-          this.clearThrottle();
-        } else {
-          this.add(this.throttled = innerSubscription);
-        }
+        this.add(this.throttled = innerSubscription);
       }
     }
   }