Giant blob of minor changes

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

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 79f0c18a395f959711043c81d2493746e31949dd..8c298480829f893a88a6994e4489b609e48fe61b 100644 (file)
--- 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) {