import { StreamCloseCode } from "./StreamCloseCode";
import { StreamState } from "./StreamState";
declare type WriterCallback<B extends boolean> = (write: (B extends true ? ((data: ArrayBuffer) => void) : ((data: any, processComplexTypes?: boolean) => void)), end: (B extends true ? ((data?: ArrayBuffer) => void) : ((data?: any, processComplexTypes?: boolean) => void))) => void | Promise<void>;
interface TimeoutOption {
    acceptTimeout?: number;
    sizePermissionTimeout?: number | null;
    endClosureTimeout?: number | null;
}
export default class WriteStream<B extends boolean = false> {
    private readonly acceptTimeout;
    private readonly sizePermissionTimeout;
    private readonly endClosureTimeout;
    readonly transmitted: boolean;
    readonly binary: boolean;
    get object(): boolean;
    readonly state: StreamState;
    private _allowedSize;
    private _sentSize;
    private _resolveSizePermissionWait;
    private _cancelLowSendBackpressureWait;
    private _writeLock;
    private _closePromiseResolve;
    readonly closed: Promise<StreamCloseCode | number>;
    private _openedPromiseResolve;
    readonly opened: Promise<void>;
    readonly closeCode?: StreamCloseCode | number;
    private _id;
    private _transport;
    private _acceptTimeoutTicker;
    private _endClosureTimeoutTicker;
    private _eofSent;
    constructor(binary?: B, timeouts?: TimeoutOption);
    useWriter(callback: WriterCallback<B>): void;
    private get remainingSizeAllowed();
    private waitForMoreSizePermission;
    private waitForLowSendBackpressure;
    private _allowSize;
    private binaryWrite;
    private _internalSendBinaryChunked;
    private objectWrite;
    readonly write: (B extends true ? ((data: ArrayBuffer | null) => Promise<boolean>) : ((data: any | null, processComplexTypes?: boolean) => Promise<boolean>));
    private binaryEnd;
    private objectEnd;
    readonly end: (B extends true ? ((data?: ArrayBuffer) => Promise<boolean>) : ((data?: any, processComplexTypes?: boolean) => Promise<boolean>));
    private _sendBinaryChunk;
    private _sendObjectChunk;
    private _sendStreamEnd;
    private _onEOFSend;
    get closedSuccessfully(): boolean;
    close(closeCode: Exclude<StreamCloseCode, StreamCloseCode.End> | number): void;
    private _close;
}
export {};