import { Operator } from '../Operator'; import { Observable } from '../Observable'; import { Subscriber } from '../Subscriber'; import { Subscription } from '../Subscription'; import { OuterSubscriber } from '../OuterSubscriber'; import { InnerSubscriber } from '../InnerSubscriber'; import { OperatorFunction } from '../interfaces'; /** * Applies an accumulator function over the source Observable where the * accumulator function itself returns an Observable, then each intermediate * Observable returned is merged into the output Observable. * * It's like {@link scan}, but the Observables returned * by the accumulator are merged into the outer Observable. * * @example Count the number of click events * const click$ = Rx.Observable.fromEvent(document, 'click'); * const one$ = click$.mapTo(1); * const seed = 0; * const count$ = one$.mergeScan((acc, one) => Rx.Observable.of(acc + one), seed); * count$.subscribe(x => console.log(x)); * * // Results: * 1 * 2 * 3 * 4 * // ...and so on for each click * * @param {function(acc: R, value: T): Observable} accumulator * The accumulator function called on each source value. * @param seed The initial accumulation value. * @param {number} [concurrent=Number.POSITIVE_INFINITY] Maximum number of * input Observables being subscribed to concurrently. * @return {Observable} An observable of the accumulated values. * @method mergeScan * @owner Observable */ export declare function mergeScan(accumulator: (acc: R, value: T) => Observable, seed: R, concurrent?: number): OperatorFunction; export declare class MergeScanOperator implements Operator { private accumulator; private seed; private concurrent; constructor(accumulator: (acc: R, value: T) => Observable, seed: R, concurrent: number); call(subscriber: Subscriber, source: any): any; } /** * We need this JSDoc comment for affecting ESDoc. * @ignore * @extends {Ignored} */ export declare class MergeScanSubscriber extends OuterSubscriber { private accumulator; private acc; private concurrent; private hasValue; private hasCompleted; private buffer; private active; protected index: number; constructor(destination: Subscriber, accumulator: (acc: R, value: T) => Observable, acc: R, concurrent: number); protected _next(value: any): void; private _innerSub(ish, value, index); protected _complete(): void; notifyNext(outerValue: T, innerValue: R, outerIndex: number, innerIndex: number, innerSub: InnerSubscriber): void; notifyComplete(innerSub: Subscription): void; }