import type { HarnessStreamPart, RunContext, StreamCallbackConfig, StreamCallbackPayload, StreamCallbackSink } from '../types/index.js';
export interface StreamCallbackAdapter {
    onStreamPart: (context: RunContext, part: HarnessStreamPart) => Promise<void>;
    flush: (timeoutMs?: number) => Promise<void>;
    close: (timeoutMs?: number) => Promise<void>;
}
export declare function createConsoleStreamSink(options?: {
    logger?: Pick<Console, 'log'>;
    prefix?: string;
}): StreamCallbackSink;
export declare function createFileStreamSink(config: {
    path?: string;
    directory?: string;
    filename?: string | ((payload: StreamCallbackPayload) => string);
    mkdirp?: boolean;
    format?: 'jsonl' | 'text';
}): StreamCallbackSink;
export declare function createFunctionStreamSink(handler: (payload: StreamCallbackPayload) => Promise<void> | void, name?: string): StreamCallbackSink;
export declare function createHttpStreamSink(config: {
    url: string;
    method?: 'POST' | 'PUT';
    headers?: Record<string, string>;
    timeoutMs?: number;
}): StreamCallbackSink;
export declare function createStreamCallbackAdapter(config?: StreamCallbackConfig): StreamCallbackAdapter;