import { Duplex } from "node:stream";
import { StreamPayload } from "../proto/dapr/proto/common/v1/common_pb";
interface MessageWithPayload {
    payload?: StreamPayload;
}
/**
 * DeferredAsyncIterable allows pushing values into an async iterable from outside.
 */
export declare class DeferredAsyncIterable<T> implements AsyncIterable<T> {
    private queue;
    private resolve?;
    private done;
    push(value: T): void;
    end(): void;
    [Symbol.asyncIterator](): AsyncGenerator<T>;
}
/**
 * DaprChunkedStream is a Duplex stream that bridges Node.js stream I/O to ConnectRPC
 * bidi-streaming calls. Write data to it; read the encrypted/decrypted output back.
 */
export declare class DaprChunkedStream<T, U extends MessageWithPayload> extends Duplex {
    private readonly pusher;
    private writeSeq;
    private readonly createMessage;
    constructor(pusher: DeferredAsyncIterable<T>, responseIterable: AsyncIterable<U>, createMessage: (data: Uint8Array, seq: number) => T);
    private _readResponseStream;
    _read(): void;
    _write(chunk: Buffer | string, encoding: BufferEncoding, callback: (error?: Error | null) => void): void;
    _final(callback: (error?: Error | null | undefined) => void): void;
}
export {};