UNPKG

745 BTypeScriptView Raw
1import { AsyncIterableX } from './asynciterablex';
2export declare class ScanAsyncIterable<T, R> extends AsyncIterableX<R> {
3 private _source;
4 private _fn;
5 private _seed?;
6 private _hasSeed;
7 constructor(source: AsyncIterable<T>, fn: (acc: R, x: T, index: number) => R | Promise<R>, seed: R[]);
8 [Symbol.asyncIterator](): AsyncIterableIterator<R>;
9}
10export declare function scan<T, R = T>(source: AsyncIterable<T>, accumulator: (previousValue: R, currentValue: T, currentIndex: number) => R | Promise<R>, seed?: never[]): AsyncIterableX<R>;
11export declare function scan<T, R = T>(source: AsyncIterable<T>, accumulator: (previousValue: R, currentValue: T, currentIndex: number) => R | Promise<R>, seed?: R): AsyncIterableX<R>;