/** * M7 — SSE (Server-Sent Events) consumer for the CLI. `invokeStreaming` * POSTs `?stream=true` to the invoke endpoint and emits each SSE frame * as one NDJSON line on stdout: `{"event":"stage.start","data":{...}}\n`. * * Pipe through `jq` for pretty-printed per-stage outputs: * agentsmarket pipeline call --stream --inputs '{}' | jq -c '.event + " " + (.data.stage_id // "")' * * On `run.error` the consumer exits non-zero and prints the error to * stderr so callers (humans or scripts) can detect failure. */ export interface SseEvent { event: string; data: unknown; } export declare function invokeStreaming(pipelineId: string, inputs: Record, slug: string): Promise; export declare function parseSseFrame(frame: string): SseEvent | null;