Function filterExample

examples/streaming/main.go:109–129

filterExample 演示过滤事件

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

// filterExample 演示过滤事件
func filterExample(ctx context.Context, ag *agent.Agent) {
	// 只处理来自 assistant 的事件
	reader := agent.StreamFilter(
		ag.Stream(ctx, "Tell me a joke"),
		func(event *session.Event) bool {
			return event.Author == "assistant"
		},
	)

	for {
		event, err := reader.Recv()
		if err != nil {
			if errors.Is(err, io.EOF) {
				break
			}
			log.Printf("Error: %v", err)
			break
		}
		fmt.Printf("Assistant says: %s\n", event.Content.Content)
	}
}

// lastEventExample 演示获取最后一个事件
func lastEventExample(ctx context.Context, ag *agent.Agent) {