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%2Fdebounce.js;h=4737d8f5f33f3127347747f56a79d0ba90c05b0b;hp=e95c94eecdfe9ddeb5fff56136229963abcde5d4;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/debounce.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/debounce.js index e95c94ee..4737d8f5 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/debounce.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/debounce.js @@ -1,5 +1,4 @@ -import { OuterSubscriber } from '../OuterSubscriber'; -import { subscribeToResult } from '../util/subscribeToResult'; +import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe'; export function debounce(durationSelector) { return (source) => source.lift(new DebounceOperator(durationSelector)); } @@ -11,12 +10,11 @@ class DebounceOperator { return source.subscribe(new DebounceSubscriber(subscriber, this.durationSelector)); } } -class DebounceSubscriber extends OuterSubscriber { +class DebounceSubscriber extends SimpleOuterSubscriber { constructor(destination, durationSelector) { super(destination); this.durationSelector = durationSelector; this.hasValue = false; - this.durationSubscription = null; } _next(value) { try { @@ -41,12 +39,12 @@ class DebounceSubscriber extends OuterSubscriber { subscription.unsubscribe(); this.remove(subscription); } - subscription = subscribeToResult(this, duration); + subscription = innerSubscribe(duration, new SimpleInnerSubscriber(this)); if (subscription && !subscription.closed) { this.add(this.durationSubscription = subscription); } } - notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) { + notifyNext() { this.emitValue(); } notifyComplete() { @@ -57,11 +55,11 @@ class DebounceSubscriber extends OuterSubscriber { const value = this.value; const subscription = this.durationSubscription; if (subscription) { - this.durationSubscription = null; + this.durationSubscription = undefined; subscription.unsubscribe(); this.remove(subscription); } - this.value = null; + this.value = undefined; this.hasValue = false; super._next(value); }