Giant blob of minor changes

[dotfiles/.git] / .config / coc / extensions / node_modules / coc-prettier / node_modules / rxjs / _esm2015 / internal / operators / buffer.js

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 db793d0a6a7686d2197fd6ed1348997fb010738b..b24311e0068d2b14286aec28f64707abf61d2524 100644 (file)
--- 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);