1
agent.subscribe((event) => {
2
  if (event.type !== "message_update") return;
3

4
  const e = event.assistantMessageEvent;
5

6
  switch (e.type) {
7
    case "text_delta":
8
      process.stdout.write(e.delta);  // 文本增量（必用）
9
      break;
10

11
    case "toolcall_delta":
12
      // 可选：显示参数生成过程
13
      console.log("[参数]", e.delta);
14
      break;
15

16
    case "thinking_delta":
17
      // 可选：显示思考过程
18
      console.log("[思考]", e.delta);
19
      break;
20
  }
21
});

1
agent.subscribe((event) => {
2
  if (event.type !== "message_end") return;
3

4
  const msg = event.message;
5
  if (msg.role !== "assistant") return;
6

7
  // Token用量
8
  console.log("Input:", msg.usage.input);
9
  console.log("Output:", msg.usage.output);
10
  console.log("Total:", msg.usage.totalTokens);
11

12
  // 判断后续行为
13
  switch (msg.stopReason) {
14
    case "stop":
15
      console.log("对话完成");
16
      break;
17
    case "toolUse":
18
      console.log("即将执行工具");
19
      break;
20
    case "error":
21
      console.log("错误:", msg.errorMessage);
22
      break;
23
  }
24
});

1
agent.subscribe((event) => {
2
  // 开始执行
3
  if (event.type === "tool_execution_start") {
4
    console.log(`[执行] ${event.toolName}`);
5
    console.log(`[参数]`, event.args);
6
  }
7

8
  // 执行完成
9
  if (event.type === "tool_execution_end") {
10
    if (event.isError) {
11
      console.error(`[失败] ${event.toolName}`);
12
      console.error(`[错误]`, event.result);
13
    } else {
14
      console.log(`[完成] ${event.toolName}`);
15
      console.log(`[结果]`, event.result);
16
    }
17
  }
18
});

1
agent.subscribe((event) => {
2
  // 1. API流式错误（最高优先级）
3
  if (event.type === "message_update") {
4
    const e = event.assistantMessageEvent;
5

6
    if (e.type === "error") {
7
      if (e.reason === "aborted") {
8
        console.log("[用户中止]");
9
      } else {
10
        console.error("[API错误]", e.error.errorMessage);
11
      }
12
      return;  // 错误后不再处理
13
    }
14
  }
15

16
  // 2. 消息完成时检查错误状态
17
  if (event.type === "message_end") {
18
    const msg = event.message;
19
    if (msg.role === "assistant") {
20
      if (msg.stopReason === "error") {
21
        console.error("[消息错误]", msg.errorMessage);
22
      }
23
      if (msg.stopReason === "aborted") {
24
        console.log("[请求中止]");
25
      }
26
    }
27
  }
28

29
  // 3. 工具执行错误
30
  if (event.type === "tool_execution_end") {
31
    if (event.isError) {
32
      console.error(`[工具失败] ${event.toolName}`);
33
    }
34
  }
35
});