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
* @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;
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;
}