import type { ProviderEvent } from '../../../provider.js';
import type { TraceSink } from '../../../trace/index.js';
import { type StreamState } from '../translate.js';
export interface IterationResult {
    state: StreamState;
    events: ProviderEvent[];
    text: string;
    needsToolDispatch: boolean;
}
export interface StreamDriveStrategy<TEvent> {
    createStream: (signal: AbortSignal) => Promise<AsyncIterable<TEvent>>;
    translate: (event: TEvent, state: StreamState) => Iterable<ProviderEvent>;
    clarifyError: (err: unknown) => Error;
}
export interface StreamDriveContext {
    controller: AbortController;
    traceWriter: TraceSink | undefined;
    initSessionId: string;
    currentModel: string;
    isClosed: () => boolean;
}
export declare function driveStream<TEvent>(ctx: StreamDriveContext, strategy: StreamDriveStrategy<TEvent>): AsyncGenerator<ProviderEvent, IterationResult | null>;