Giant blob of minor changes

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

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/throttle.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/throttle.js
index fc073178ac53de32c5fd977257a5908862acd188..6b32790d8e59bb713611fb037c28d19f77725c00 100644 (file)
--- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/throttle.js
+++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/throttle.js
@@ -1,11 +1,10 @@
-import { OuterSubscriber } from '../OuterSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
 export const defaultThrottleConfig = {
     leading: true,
     trailing: false
 };
 export function throttle(durationSelector, config = defaultThrottleConfig) {
-    return (source) => source.lift(new ThrottleOperator(durationSelector, config.leading, config.trailing));
+    return (source) => source.lift(new ThrottleOperator(durationSelector, !!config.leading, !!config.trailing));
 }
 class ThrottleOperator {
     constructor(durationSelector, leading, trailing) {
@@ -17,7 +16,7 @@ class ThrottleOperator {
         return source.subscribe(new ThrottleSubscriber(subscriber, this.durationSelector, this.leading, this.trailing));
     }
 }
-class ThrottleSubscriber extends OuterSubscriber {
+class ThrottleSubscriber extends SimpleOuterSubscriber {
     constructor(destination, durationSelector, _leading, _trailing) {
         super(destination);
         this.destination = destination;
@@ -45,12 +44,12 @@ class ThrottleSubscriber extends OuterSubscriber {
             this.throttle(_sendValue);
         }
         this._hasValue = false;
-        this._sendValue = null;
+        this._sendValue = undefined;
     }
     throttle(value) {
         const duration = this.tryDurationSelector(value);
         if (!!duration) {
-            this.add(this._throttled = subscribeToResult(this, duration));
+            this.add(this._throttled = innerSubscribe(duration, new SimpleInnerSubscriber(this)));
         }
     }
     tryDurationSelector(value) {
@@ -67,12 +66,12 @@ class ThrottleSubscriber extends OuterSubscriber {
         if (_throttled) {
             _throttled.unsubscribe();
         }
-        this._throttled = null;
+        this._throttled = undefined;
         if (_trailing) {
             this.send();
         }
     }
-    notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
+    notifyNext() {
         this.throttlingDone();
     }
     notifyComplete() {