/** * Merges multiple async generators into a single async generator. * * @param generators - The generators to merge. * @returns A single async generator that yields results from all input generators. */ export declare function mergeAsyncGenerators(generators: AsyncGenerator[]): AsyncGenerator; /** * Buffers the results of an async generator. * * @param generator - The generator to buffer. * @param size - The size of the buffer. * @returns An async generator that yields results from the input generator. */ export declare function bufferAsyncGenerator(generator: AsyncGenerator, size: number, bufferCallback?: (bufferSize: number) => void): AsyncGenerator; /** * Drains an async generator into an array. * * @param asyncGenerator - The async generator to drain. * @returns An array of results from the input generator. */ export declare function drainAsyncGenerator(asyncGenerator: AsyncGenerator): Promise; /** * Records the total time taken to yield results from an async generator. * * @param asyncGenerator - The async generator to record. * @param callback - A callback function that receives duration metrics. * @returns An async generator that yields results from the input generator. */ export declare function recordAsyncGenerator(asyncGenerator: AsyncGenerator, callback: (params: { await: number; yield: number; total: number; }) => void): AsyncGenerator; /** * Creates an async generator that yields values from a callback. */ export declare function createCallbackGenerator(bufferCallback?: (bufferSize: number) => void): { callback: (value: T) => void; generator: AsyncGenerator; }; //# sourceMappingURL=generators.d.ts.map