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%2FskipUntil.js;h=a0f54e3f32fba6849370abc1d0c39a7fb2368e62;hp=4909c5d8c022854386c968bf90f18f8d50904797;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/skipUntil.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/skipUntil.js index 4909c5d8..a0f54e3f 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/skipUntil.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/skipUntil.js @@ -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();