Giant blob of minor changes

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

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/repeatWhen.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/repeatWhen.js
index fea24e28c2a9c1375f41e6beb9effce086e07036..027eaa09dd7ed400892ce8aa96323f360abc23bb 100644 (file)
--- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/repeatWhen.js
+++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/repeatWhen.js
@@ -1,6 +1,5 @@
 import { Subject } from '../Subject';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
 export function repeatWhen(notifier) {
     return (source) => source.lift(new RepeatWhenOperator(notifier));
 }
@@ -12,18 +11,18 @@ class RepeatWhenOperator {
         return source.subscribe(new RepeatWhenSubscriber(subscriber, this.notifier, source));
     }
 }
-class RepeatWhenSubscriber extends OuterSubscriber {
+class RepeatWhenSubscriber extends SimpleOuterSubscriber {
     constructor(destination, notifier, source) {
         super(destination);
         this.notifier = notifier;
         this.source = source;
         this.sourceIsBeingSubscribedTo = true;
     }
-    notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
+    notifyNext() {
         this.sourceIsBeingSubscribedTo = true;
         this.source.subscribe(this);
     }
-    notifyComplete(innerSub) {
+    notifyComplete() {
         if (this.sourceIsBeingSubscribedTo === false) {
             return super.complete();
         }
@@ -38,20 +37,20 @@ class RepeatWhenSubscriber extends OuterSubscriber {
                 return super.complete();
             }
             this._unsubscribeAndRecycle();
-            this.notifications.next();
+            this.notifications.next(undefined);
         }
     }
     _unsubscribe() {
         const { notifications, retriesSubscription } = this;
         if (notifications) {
             notifications.unsubscribe();
-            this.notifications = null;
+            this.notifications = undefined;
         }
         if (retriesSubscription) {
             retriesSubscription.unsubscribe();
-            this.retriesSubscription = null;
+            this.retriesSubscription = undefined;
         }
-        this.retries = null;
+        this.retries = undefined;
     }
     _unsubscribeAndRecycle() {
         const { _unsubscribe } = this;
@@ -71,7 +70,7 @@ class RepeatWhenSubscriber extends OuterSubscriber {
             return super.complete();
         }
         this.retries = retries;
-        this.retriesSubscription = subscribeToResult(this, retries);
+        this.retriesSubscription = innerSubscribe(retries, new SimpleInnerSubscriber(this));
     }
 }
 //# sourceMappingURL=repeatWhen.js.map
\ No newline at end of file