Giant blob of minor changes

[dotfiles/.git] / .config / coc / extensions / node_modules / coc-prettier / node_modules / rxjs / _esm2015 / internal / operators / audit.js

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/audit.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/audit.js
index 80618bf4cb0deb8dda14dd33250c44de080b3437..8818a087de43e2c0ce17ada57ad560af7718cc7a 100644 (file)
--- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/audit.js
+++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/audit.js
@@ -1,5 +1,4 @@
-import { OuterSubscriber } from '../OuterSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
 export function audit(durationSelector) {
     return function auditOperatorFunction(source) {
         return source.lift(new AuditOperator(durationSelector));
@@ -13,7 +12,7 @@ class AuditOperator {
         return source.subscribe(new AuditSubscriber(subscriber, this.durationSelector));
     }
 }
-class AuditSubscriber extends OuterSubscriber {
+class AuditSubscriber extends SimpleOuterSubscriber {
     constructor(destination, durationSelector) {
         super(destination);
         this.durationSelector = durationSelector;
@@ -31,7 +30,7 @@ class AuditSubscriber extends OuterSubscriber {
             catch (err) {
                 return this.destination.error(err);
             }
-            const innerSubscription = subscribeToResult(this, duration);
+            const innerSubscription = innerSubscribe(duration, new SimpleInnerSubscriber(this));
             if (!innerSubscription || innerSubscription.closed) {
                 this.clearThrottle();
             }
@@ -44,16 +43,16 @@ class AuditSubscriber extends OuterSubscriber {
         const { value, hasValue, throttled } = this;
         if (throttled) {
             this.remove(throttled);
-            this.throttled = null;
+            this.throttled = undefined;
             throttled.unsubscribe();
         }
         if (hasValue) {
-            this.value = null;
+            this.value = undefined;
             this.hasValue = false;
             this.destination.next(value);
         }
     }
-    notifyNext(outerValue, innerValue, outerIndex, innerIndex) {
+    notifyNext() {
         this.clearThrottle();
     }
     notifyComplete() {