import type { AgentRunArgs } from './agent-runner.js'; import { type QwenStreamEvent, type TurnOutcome } from './qwen-runner-parse.js'; /** Distinct from TURN_TIMEOUT_MS: catches a hung first-run interactive prompt * (trust/telemetry gate) fast instead of waiting out the full turn timeout. * Fires only if the process has produced ZERO stdout by this point — any * output at all disarms it, since a slow model response is not a hang. * Exported: qwen-runner.ts's run() uses it to word the hang error message. */ export declare const STARTUP_GRACE_MS = 45000; /** * Run one `qwen` invocation and stream its stream-json output * INCREMENTALLY: each parsed event is yielded as soon as its line arrives * on stdout (see qwen-runner.ts's header "Streaming / liveness" note for why * buffering until process exit was a bug, #204). End-of-turn facts (exit * code, stderr tail, session id, usage, error, timeout/hang flags) are * written into `outcome`, which the caller reads after this generator * completes. */ export declare function streamTurn(bin: string, prompt: string, sessionId: string | undefined, args: AgentRunArgs, outcome: TurnOutcome): AsyncGenerator; /** Build the actionable error for a failed qwen turn. */ export declare function turnError(outcome: TurnOutcome, round: number): Error; //# sourceMappingURL=qwen-runner-stream.d.ts.map