im.ttalk.agent.provider.stream.dashscope — im.ttalk/clj-agent-provider 0.5.447

DashScope 原生流式响应处理（SSE）。

DashScope 流式：请求头 X-DashScope-SSE: enable + parameters.incremental_output true。 响应是 SSE，每个事件含 id:/event:result/:HTTP_STATUS/data: 几行，data 为 JSON： {:output {:choices [{:finish_reason fr :message {:role :content delta}}]} :usage {...} :request_id ...} incremental_output=true 时 content 是增量（delta）。finish_reason 生成中为 "null"/null， 结束为 "stop"/"length" 等。

产出与同步 parse-response 同形的 OpenAI 兼容响应（extract-text 读 choices[0].message.content）。

build-response clj

(build-response state)

从最终状态构建与同步 parse-response 同形的 OpenAI 兼容响应。

make-initial-state clj

(make-initial-state)

parse-sse-line clj

(parse-sse-line line)

取 DashScope SSE 的 data 行（兼容 "data:" 有无空格），跳过 id:/event:/:HTTP_STATUS 等。

process-event clj

(process-event event state)

处理一个 DashScope SSE 事件。返回 [new-state token-data|nil]。 reasoning_content 增量 → emit {:reasoning-token r :reasoning? true}； content 增量 → emit {:token delta}；tool_calls / usage / finish_reason 累积到 state。