import type * as net from "node:net";
import { ClickHouseException } from "./types.ts";
/**
 * A streaming byte reader that handles async buffering and optional ClickHouse compression.
 * Optimized to avoid O(N^2) copies during buffering.
 */
export declare class StreamingReader {
    private source;
    private buffer;
    private offset;
    private done;
    private compressionEnabled;
    constructor(socket: net.Socket);
    setCompression(enabled: boolean): void;
    private ensure;
    private pullRawChunk;
    private pullCompressedBlock;
    private readRaw;
    private feed;
    peek(n: number): Promise<Uint8Array>;
    consume(n: number): void;
    peekAll(): Uint8Array;
    nextChunk(): Promise<boolean>;
    readVarInt(): Promise<bigint>;
    readString(): Promise<string>;
    readFixed(n: number): Promise<Uint8Array>;
    readU8(): Promise<number>;
    readU32LE(): Promise<number>;
    readInt32LE(): Promise<number>;
    readU64LE(): Promise<bigint>;
    readException(): Promise<ClickHouseException>;
    readCompressedBlock(): Promise<Uint8Array>;
    private compressedDataSize;
    private assembleAndDecodeBlock;
}
//# sourceMappingURL=reader.d.ts.map