import type { ModelStreamChunk } from './model.js';
import type { SignalEntryData, StreamChunkStore } from './types.js';
type StreamChunkEvent = ModelStreamChunk;
export interface ReconstructedPartialAssistantMessage {
    text: string;
    thinking?: string;
    stopReason: 'aborted';
    errorMessage: string;
}
export declare class StreamChunkWriter {
    private store;
    readonly streamKey: string;
    private pending;
    private segmentIndex;
    private timer;
    private flushing;
    private failed;
    private active;
    constructor(store: StreamChunkStore, streamKey: string);
    write(event: StreamChunkEvent): void;
    flush(): Promise<void>;
    close(): Promise<void>;
    cancel(): void;
}
export declare function reconstructInterruptedStream(segments: Array<{
    segmentIndex: number;
    body: string;
}>, streamKey: string): {
    partial: ReconstructedPartialAssistantMessage;
    interrupted: SignalEntryData;
    continued: SignalEntryData;
} | null;
export declare class InMemoryStreamChunkStore implements StreamChunkStore {
    private segments;
    appendStreamChunkSegment(streamKey: string, segmentIndex: number, body: string): Promise<boolean>;
    getStreamChunkSegments(streamKey: string): Promise<Array<{
        segmentIndex: number;
        body: string;
    }>>;
}
export {};
//# sourceMappingURL=stream-chunks.d.ts.map