import type { SinkWriter, StreamFrame, TokenStreamSink } from './spi/token-stream-sink.js';
/**
 * The default {@link TokenStreamSink}: buffers typed frames per run in-process so a reconnecting
 * subscriber replays everything so far, then follows live until the run ends. Good for a single
 * replica; a multi-replica deployment needs a shared (Redis) sink so any pod can serve any run's
 * stream. Identical (frame-for-frame) to the `InMemoryTokenStreamSink` shipped from `./testing`.
 */
export declare class InProcessTokenStreamSink 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-process-sink.d.ts.map