import type { AgentResponse } from "../types.js";
import type { AgUiSseEvent } from "./host-support.js";
import { type AgUiEncoderState } from "./encoder.js";
/** State for AG-UI response request. */
export interface AgUiResponseRequestState {
    runId?: string;
    threadId?: string;
    state?: unknown;
    messages: unknown[];
}
/** Public API contract for AG-UI response execution. */
export interface AgUiResponseExecution<TChunk> {
    agentUIStream: AsyncIterable<TChunk>;
    fail: (error: unknown) => Promise<void>;
    waitForFinish: () => Promise<void>;
}
/** Public API contract for AG-UI response encoder. */
export interface AgUiResponseEncoder<TChunk> {
    encode: (chunk: TChunk) => AgUiSseEvent[];
    finalize: (response: AgentResponse | null) => AgUiSseEvent[];
    /** Shared timing anchor for bootstrap, chunk, and final events. */
    timingState?: AgUiEncoderState;
}
/** Input payload for create AG-UI response stream. */
export interface CreateAgUiResponseStreamInput<TChunk, TState> {
    agUiInput: AgUiResponseRequestState;
    agentId: string;
    execution: AgUiResponseExecution<TChunk>;
    encoder: AgUiResponseEncoder<TChunk>;
    initialState: TState;
    onChunk?: (state: TState, chunk: TChunk) => void;
    getFinalResponse?: (state: TState) => AgentResponse | null;
}
/** Create AG-UI response stream. */
export declare function createAgUiResponseStream<TChunk, TState>(input: CreateAgUiResponseStreamInput<TChunk, TState>): ReadableStream<Uint8Array>;
//# sourceMappingURL=response-stream.d.ts.map