Function collectExample

examples/streaming/main.go:95–106

collectExample 演示收集所有事件

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

// collectExample 演示收集所有事件
func collectExample(ctx context.Context, ag *agent.Agent) {
	// 收集所有事件到切片
	events, err := agent.StreamCollect(ag.Stream(ctx, "List files in current directory"))
	if err != nil {
		log.Fatalf("Stream error: %v", err)
	}

	fmt.Printf("Total events collected: %d\n", len(events))
	for i, event := range events {
		fmt.Printf("[%d] %s: %s\n", i+1, event.Author, truncateContent(event.Content.Content, 30))
	}
}

// filterExample 演示过滤事件
func filterExample(ctx context.Context, ag *agent.Agent) {