import { Pool, PoolOptions } from './Pool';
import { Callback } from '../../constants';
export interface WriteableOptions extends PoolOptions {
    batchConsume?: boolean;
    consumeNum?: number;
    consumeImme?: boolean;
    consumeCheckInterval?: number;
    maxConsumeIdleTime?: number;
}
export declare class Writeable extends Pool {
    protected readonly batchConsume: boolean;
    protected readonly consumeNum: number;
    protected readonly consumeCheckInterval?: number;
    protected readonly maxConsumeIdleTime?: number;
    private consumeImme?;
    private lastConsumeTime;
    private checkTid;
    private isWriting;
    private isClosing;
    private isStopping;
    private writeLen;
    private readonly onAfterWrite;
    private writeCb;
    private closeCb;
    private flushPromise;
    private emptyCb;
    constructor({ batchConsume, consumeNum, consumeImme, consumeCheckInterval, maxConsumeIdleTime, ...opts }?: WriteableOptions);
    start(): void;
    stop(): void;
    write(chunk: any, cb?: any): boolean;
    close(): void;
    flush(): Promise<void>;
    startPollingCheck(): void;
    stopPollingCheck(): void;
    private doWrite;
    protected _write(_chunk: unknown, _cb: Callback): void;
    protected _writev(_chunks: Array<unknown>, _cb: Callback): void;
    protected _destroy(): void;
}