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%2FtakeUntil.js;h=9bd558b986904d830e16cbfd4c0cc5521d657636;hp=87778e2a4afac06f9c6f11e813e445fae8ebc698;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/takeUntil.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/takeUntil.js
index 87778e2a..9bd558b9 100644
--- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/takeUntil.js
+++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/takeUntil.js
@@ -1,5 +1,4 @@
-import { OuterSubscriber } from '../OuterSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { innerSubscribe, SimpleInnerSubscriber, SimpleOuterSubscriber } from '../innerSubscribe';
 export function takeUntil(notifier) {
     return (source) => source.lift(new TakeUntilOperator(notifier));
 }
@@ -9,7 +8,7 @@ class TakeUntilOperator {
     }
     call(subscriber, source) {
         const takeUntilSubscriber = new TakeUntilSubscriber(subscriber);
-        const notifierSubscription = subscribeToResult(takeUntilSubscriber, this.notifier);
+        const notifierSubscription = innerSubscribe(this.notifier, new SimpleInnerSubscriber(takeUntilSubscriber));
         if (notifierSubscription && !takeUntilSubscriber.seenValue) {
             takeUntilSubscriber.add(notifierSubscription);
             return source.subscribe(takeUntilSubscriber);
@@ -17,12 +16,12 @@ class TakeUntilOperator {
         return takeUntilSubscriber;
     }
 }
-class TakeUntilSubscriber extends OuterSubscriber {
+class TakeUntilSubscriber extends SimpleOuterSubscriber {
     constructor(destination) {
         super(destination);
         this.seenValue = false;
     }
-    notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
+    notifyNext() {
         this.seenValue = true;
         this.complete();
     }