Giant blob of minor changes
[dotfiles/.git] / .config / coc / extensions / node_modules / coc-prettier / node_modules / rxjs / _esm2015 / internal / operators / skipUntil.js
index 4909c5d8c022854386c968bf90f18f8d50904797..a0f54e3f32fba6849370abc1d0c39a7fb2368e62 100644 (file)
@@ -1,6 +1,4 @@
-import { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, SimpleInnerSubscriber, innerSubscribe } from '../innerSubscribe';
 export function skipUntil(notifier) {
     return (source) => source.lift(new SkipUntilOperator(notifier));
 }
@@ -12,14 +10,14 @@ class SkipUntilOperator {
         return source.subscribe(new SkipUntilSubscriber(destination, this.notifier));
     }
 }
-class SkipUntilSubscriber extends OuterSubscriber {
+class SkipUntilSubscriber extends SimpleOuterSubscriber {
     constructor(destination, notifier) {
         super(destination);
         this.hasValue = false;
-        const innerSubscriber = new InnerSubscriber(this, undefined, undefined);
+        const innerSubscriber = new SimpleInnerSubscriber(this);
         this.add(innerSubscriber);
         this.innerSubscription = innerSubscriber;
-        const innerSubscription = subscribeToResult(this, notifier, undefined, undefined, innerSubscriber);
+        const innerSubscription = innerSubscribe(notifier, innerSubscriber);
         if (innerSubscription !== innerSubscriber) {
             this.add(innerSubscription);
             this.innerSubscription = innerSubscription;
@@ -30,7 +28,7 @@ class SkipUntilSubscriber extends OuterSubscriber {
             super._next(value);
         }
     }
-    notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
+    notifyNext() {
         this.hasValue = true;
         if (this.innerSubscription) {
             this.innerSubscription.unsubscribe();