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%2Fbuffer.js;h=b24311e0068d2b14286aec28f64707abf61d2524;hp=db793d0a6a7686d2197fd6ed1348997fb010738b;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/buffer.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/buffer.js index db793d0a..b24311e0 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/buffer.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/buffer.js @@ -1,5 +1,4 @@ -import { OuterSubscriber } from '../OuterSubscriber'; -import { subscribeToResult } from '../util/subscribeToResult'; +import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe'; export function buffer(closingNotifier) { return function bufferOperatorFunction(source) { return source.lift(new BufferOperator(closingNotifier)); @@ -13,16 +12,16 @@ class BufferOperator { return source.subscribe(new BufferSubscriber(subscriber, this.closingNotifier)); } } -class BufferSubscriber extends OuterSubscriber { +class BufferSubscriber extends SimpleOuterSubscriber { constructor(destination, closingNotifier) { super(destination); this.buffer = []; - this.add(subscribeToResult(this, closingNotifier)); + this.add(innerSubscribe(closingNotifier, new SimpleInnerSubscriber(this))); } _next(value) { this.buffer.push(value); } - notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) { + notifyNext() { const buffer = this.buffer; this.buffer = []; this.destination.next(buffer);