Function streamingExample

examples/streaming/main.go:66–92

streamingExample 演示流式处理事件

(ctx context.Context, ag *agent.Agent)

// streamingExample 演示流式处理事件
func streamingExample(ctx context.Context, ag *agent.Agent) {
	// 使用 Recv 循环迭代事件流
	reader := ag.Stream(ctx, "What is 2+2?")
	for {
		event, err := reader.Recv()
		if err != nil {
			if errors.Is(err, io.EOF) {
				break
			}
			log.Printf("Error: %v", err)
			break
		}

		// 实时处理每个事件
		fmt.Printf("[Event %s] Author: %s, Content: %s\n",
			event.ID[:8],
			event.Author,
			truncateContent(event.Content.Content, 50),
		)

		// 可以根据条件中断流
		if event.Actions.Escalate {
			fmt.Println("Escalation detected, stopping stream")
			break
		}
	}
}

// collectExample 演示收集所有事件
func collectExample(ctx context.Context, ag *agent.Agent) {