import type { SinkWriter, StreamFrame, TokenStreamSink } from '../index.js';
/**
 * In-memory `TokenStreamSink`. Buffers typed frames per run so a late subscriber (reconnect)
 * replays everything emitted so far, then follows live until the run ends.
 */
export declare class InMemoryTokenStreamSink implements TokenStreamSink {
    private readonly runs;
    private buffer;
    private wake;
    open(runId: string): SinkWriter;
    subscribe(runId: string): AsyncIterable<StreamFrame>;
    has(runId: string): boolean;
    close(runId: string): void;
}
//# sourceMappingURL=in-memory-sink.d.ts.map