X-Git-Url: https://git.josue.xyz/?p=dotfiles%2F.git;a=blobdiff_plain;f=.config%2Fcoc%2Fextensions%2Fnode_modules%2Fcoc-prettier%2Fnode_modules%2Frxjs%2F_esm2015%2Finternal%2Foperators%2FretryWhen.js;h=0f3aa2fbf76311235352f4fe5079c458cfe85f83;hp=87fef62c2de1705ddbdee4f69498b6f1ee2ef620;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/retryWhen.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/retryWhen.js
index 87fef62c..0f3aa2fb 100644
--- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/retryWhen.js
+++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/retryWhen.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 retryWhen(notifier) {
     return (source) => source.lift(new RetryWhenOperator(notifier, source));
 }
@@ -13,7 +12,7 @@ class RetryWhenOperator {
         return source.subscribe(new RetryWhenSubscriber(subscriber, this.notifier, this.source));
     }
 }
-class RetryWhenSubscriber extends OuterSubscriber {
+class RetryWhenSubscriber extends SimpleOuterSubscriber {
     constructor(destination, notifier, source) {
         super(destination);
         this.notifier = notifier;
@@ -33,11 +32,11 @@ class RetryWhenSubscriber extends OuterSubscriber {
                 catch (e) {
                     return super.error(e);
                 }
-                retriesSubscription = subscribeToResult(this, retries);
+                retriesSubscription = innerSubscribe(retries, new SimpleInnerSubscriber(this));
             }
             else {
-                this.errors = null;
-                this.retriesSubscription = null;
+                this.errors = undefined;
+                this.retriesSubscription = undefined;
             }
             this._unsubscribeAndRecycle();
             this.errors = errors;
@@ -50,15 +49,15 @@ class RetryWhenSubscriber extends OuterSubscriber {
         const { errors, retriesSubscription } = this;
         if (errors) {
             errors.unsubscribe();
-            this.errors = null;
+            this.errors = undefined;
         }
         if (retriesSubscription) {
             retriesSubscription.unsubscribe();
-            this.retriesSubscription = null;
+            this.retriesSubscription = undefined;
         }
-        this.retries = null;
+        this.retries = undefined;
     }
-    notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
+    notifyNext() {
         const { _unsubscribe } = this;
         this._unsubscribe = null;
         this._unsubscribeAndRecycle();