AI-Agent

5.3 流式输出处理

集成到 Agent

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
async function processStreaming(userInput: string): Promise<void> {
  this.conversation.addMessage('user', userInput);
  const messages = this.conversation.getMessages();
  
  process.stdout.write('助手: ');
  
  let fullResponse = '';
  for await (const { content, done } of this.streamChat(messages)) {
    if (content) {
      process.stdout.write(content);
      fullResponse += content;
    }
    if (done) {
      console.log('\n');
      this.conversation.addMessage('assistant', fullResponse);
      break;
    }
  }
}

Step 3 总结

  • ✅ 流式 API 调用
  • ✅ 实时输出显示
  • ✅ 响应拼接和保存

下一章： 第六章：配置管理 →

导航

上一篇： 5.2 SSE 协议实现

下一篇： 6.1 配置文件设计