UNPKG

471 BTypeScriptView Raw
1import { AsyncIterableX } from './asynciterablex';
2export declare class BufferAsyncIterable<TSource> extends AsyncIterableX<TSource[]> {
3 private _source;
4 private _count;
5 private _skip;
6 constructor(source: AsyncIterable<TSource>, count: number, skip: number);
7 [Symbol.asyncIterator](): AsyncIterableIterator<TSource[]>;
8}
9export declare function buffer<TSource>(source: AsyncIterable<TSource>, count: number, skip?: number): AsyncIterableX<TSource[]>;