import { AsyncIterableX } from '../asynciterablex.js'; import { OperatorAsyncFunction } from '../../interfaces.js'; /** @ignore */ export declare class BufferAsyncIterable extends AsyncIterableX { private _source; private _count; private _skip; constructor(source: AsyncIterable, count: number, skip: number); [Symbol.asyncIterator](signal?: AbortSignal): AsyncGenerator; } /** * Projects each element of an async-iterable sequence into consecutive non-overlapping * buffers which are produced based on element count information. * * @template TSource The type of elements in the source sequence. * @param {number} count The length of each buffer. * @param {number} [skip] An optional number of elements to skip between creation of consecutive buffers. * @returns {OperatorAsyncFunction} An operator which returns anm async-iterable sequence with * consecutive non-overlapping buffers based upon element count information. */ export declare function buffer(count: number, skip?: number): OperatorAsyncFunction; /** * Projects each element of an async-iterable sequence into consecutive non-overlapping * buffers which are produced based on element count information. * @param count Length of each buffer. * @param skip Number of elements to skip between creation of consecutive buffers. */