import { Readable } from 'stream'; import { DuckDBResult } from '@duckdb/node-api'; import { Transform } from './Transform'; /** * Streams a DuckDB result as hydrated row objects, one fetched chunk (up to 2048 rows) per * `await`. The consumer's `highWaterMark` bounds how far ahead of it the chunks are read. */ export declare class DuckDBRowStream extends Readable { private readonly result; private readonly transform; private readonly onClose; private reading; private pendingFetch; private batch; private idx; constructor(result: DuckDBResult, transform: Transform, onClose: () => void, highWaterMark: number); _read(): Promise; _destroy(error: Error | null, callback: (error?: Error | null) => void): void; } //# sourceMappingURL=RowStream.d.ts.map