import { StreamCloseCode } from "./StreamCloseCode";
import { StreamState } from "./StreamState";
import Transport from "../Transport";
import { DataType } from "../DataType";
interface ReadStreamOptions {
    bufferSize?: number;
    chunkTimeout?: number | null;
    sizeLimit?: number | null;
}
export declare type ChunkMiddleware<T = any> = (chunk: any, updateChunk: (chunk: T) => void, type: DataType) => boolean | Promise<boolean>;
export default class ReadStream<T = any> {
    readonly id: number;
    readonly state: StreamState;
    readonly accepted: boolean;
    private readPromise;
    private readResolve;
    set sizeLimit(sizeLimit: number | null);
    private _sizeLimit?;
    private _buffer;
    private _bufferSizeLimit;
    private _allowedSize;
    private _processedSize;
    private _receivedSize;
    private _chainEnd;
    private _chainCancel;
    private _chain;
    private _chainChunkSize;
    private readonly _createdBadConnectionStamp;
    private _chunkTimeoutActive;
    private _chunkTimeout;
    private _chunkTimeoutTick;
    private _allowMoreMinTimeout;
    set chunkMiddleware(middleware: ChunkMiddleware<T> | undefined);
    private _chunkMiddleware?;
    private _closedPromiseResolve;
    readonly closed: Promise<StreamCloseCode | number>;
    private _openedPromiseResolve;
    readonly opened: Promise<void>;
    readonly closeCode?: StreamCloseCode | number;
    private readonly _transport;
    constructor(id: number, transport: Transport);
    get binary(): boolean;
    get object(): boolean;
    get closedSuccessfully(): boolean;
    accept({ sizeLimit, bufferSize, chunkTimeout }?: ReadStreamOptions): void;
    close(closeCode: StreamCloseCode | number): void;
    private _checkAllowMore;
    [Symbol.asyncIterator](): AsyncGenerator<T, void, unknown>;
    read(): Promise<T | null>;
    readAll(): Promise<T[]>;
    private _setChunkTimeout;
    private _emptyChunksCheck;
    private _clearChunkTimeout;
    private _chainNextChunk;
    private _processChunk;
    private _processChainEnd;
    private _cancelChunkChain;
}
export {};