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%2Fwindow.js;h=8c298480829f893a88a6994e4489b609e48fe61b;hp=79f0c18a395f959711043c81d2493746e31949dd;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/window.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/window.js index 79f0c18a..8c298480 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/window.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/window.js @@ -1,6 +1,5 @@ import { Subject } from '../Subject'; -import { OuterSubscriber } from '../OuterSubscriber'; -import { subscribeToResult } from '../util/subscribeToResult'; +import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe'; export function window(windowBoundaries) { return function windowOperatorFunction(source) { return source.lift(new WindowOperator(windowBoundaries)); @@ -14,24 +13,24 @@ class WindowOperator { const windowSubscriber = new WindowSubscriber(subscriber); const sourceSubscription = source.subscribe(windowSubscriber); if (!sourceSubscription.closed) { - windowSubscriber.add(subscribeToResult(windowSubscriber, this.windowBoundaries)); + windowSubscriber.add(innerSubscribe(this.windowBoundaries, new SimpleInnerSubscriber(windowSubscriber))); } return sourceSubscription; } } -class WindowSubscriber extends OuterSubscriber { +class WindowSubscriber extends SimpleOuterSubscriber { constructor(destination) { super(destination); this.window = new Subject(); destination.next(this.window); } - notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) { + notifyNext() { this.openWindow(); } - notifyError(error, innerSub) { + notifyError(error) { this._error(error); } - notifyComplete(innerSub) { + notifyComplete() { this._complete(); } _next(value) {