import { Writable } from 'node:stream';
import { type CallbackWithPromise } from '../../apis/callbacks.ts';
import type { MessageToProduce } from '../../protocol/records.ts';
import type { Producer } from './producer.ts';
import { type ProducerStreamOptions } from './types.ts';
export declare class ProducerStream<Key = Buffer, Value = Buffer, HeaderKey = Buffer, HeaderValue = Buffer> extends Writable {
    #private;
    instance: number;
    constructor(producer: Producer<Key, Value, HeaderKey, HeaderValue>, options: ProducerStreamOptions<Key, Value, HeaderKey, HeaderValue>);
    get producer(): Producer<Key, Value, HeaderKey, HeaderValue>;
    close(callback: CallbackWithPromise<void>): void;
    close(): Promise<void>;
    _write(message: MessageToProduce<Key, Value, HeaderKey, HeaderValue>, _: BufferEncoding, callback: (error?: Error | null) => void): void;
    _writev(chunks: Array<{
        chunk: MessageToProduce<Key, Value, HeaderKey, HeaderValue>;
    }>, callback: (error?: Error | null) => void): void;
    _final(callback: (error?: Error | null) => void): void;
    _destroy(error: Error | null, callback: (error?: Error | null) => void): void;
}