Giant blob of minor changes
[dotfiles/.git] / .config / coc / extensions / node_modules / coc-prettier / node_modules / rxjs / internal / operators / mergeScan.d.ts
index eeabf3b0e4cbe49f0b0808151a9ce95615a54fa6..d4198e5621ba4ef09e85eae9ce0727175fa9f2d7 100644 (file)
@@ -1,9 +1,7 @@
 import { Operator } from '../Operator';
 import { Subscriber } from '../Subscriber';
-import { Subscription } from '../Subscription';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
 import { ObservableInput, OperatorFunction } from '../types';
+import { SimpleOuterSubscriber } from '../innerSubscribe';
 /**
  * Applies an accumulator function over the source Observable where the
  * accumulator function itself returns an Observable, then each intermediate
@@ -56,7 +54,7 @@ export declare class MergeScanOperator<T, R> implements Operator<T, R> {
  * @ignore
  * @extends {Ignored}
  */
-export declare class MergeScanSubscriber<T, R> extends OuterSubscriber<T, R> {
+export declare class MergeScanSubscriber<T, R> extends SimpleOuterSubscriber<T, R> {
     private accumulator;
     private acc;
     private concurrent;
@@ -69,6 +67,6 @@ export declare class MergeScanSubscriber<T, R> extends OuterSubscriber<T, R> {
     protected _next(value: any): void;
     private _innerSub;
     protected _complete(): void;
-    notifyNext(outerValue: T, innerValue: R, outerIndex: number, innerIndex: number, innerSub: InnerSubscriber<T, R>): void;
-    notifyComplete(innerSub: Subscription): void;
+    notifyNext(innerValue: R): void;
+    notifyComplete(): void;
 }