Actualizacion maquina principal

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

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
new file mode 100644 (file)
index 0000000..87778e2
--- /dev/null
+++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/takeUntil.js
@@ -0,0 +1,32 @@
+import { OuterSubscriber } from '../OuterSubscriber';
+import { subscribeToResult } from '../util/subscribeToResult';
+export function takeUntil(notifier) {
+    return (source) => source.lift(new TakeUntilOperator(notifier));
+}
+class TakeUntilOperator {
+    constructor(notifier) {
+        this.notifier = notifier;
+    }
+    call(subscriber, source) {
+        const takeUntilSubscriber = new TakeUntilSubscriber(subscriber);
+        const notifierSubscription = subscribeToResult(takeUntilSubscriber, this.notifier);
+        if (notifierSubscription && !takeUntilSubscriber.seenValue) {
+            takeUntilSubscriber.add(notifierSubscription);
+            return source.subscribe(takeUntilSubscriber);
+        }
+        return takeUntilSubscriber;
+    }
+}
+class TakeUntilSubscriber extends OuterSubscriber {
+    constructor(destination) {
+        super(destination);
+        this.seenValue = false;
+    }
+    notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
+        this.seenValue = true;
+        this.complete();
+    }
+    notifyComplete() {
+    }
+}
+//# sourceMappingURL=takeUntil.js.map
\ No newline at end of file