import { type RuntimeBlock } from "../types.js";
/** One consumer; consecutive text deltas are combined before they enter its queue. */
export declare class RuntimeBlockBuffer {
    private readonly consume;
    private readonly onFailure;
    private pending;
    private deltaText;
    private deltaKind;
    private timer;
    private draining;
    private failure;
    private closed;
    constructor(consume: (block: RuntimeBlock) => Promise<void>, onFailure: () => void);
    add(block: RuntimeBlock): void;
    finish(): Promise<void>;
    private flushDelta;
    private fail;
    private enqueue;
}