Function StreamCollect

pkg/agent/streaming.go:175–190

StreamCollect 辅助函数 - 收集所有事件 用于向后兼容，将流式接口转换为批量结果 使用示例: events, err := StreamCollect(agent.Stream(ctx, "Hello")) if err != nil { return err } for _, event := range events { fmt.Println(event) }

(reader *stream.Reader[*session.Event])

//	    fmt.Println(event)
//	}
func StreamCollect(reader *stream.Reader[*session.Event]) ([]*session.Event, error) {
	var events []*session.Event
	for {
		event, err := reader.Recv()
		if err != nil {
			if errors.Is(err, io.EOF) {
				break
			}
			return events, err
		}
		if event != nil {
			events = append(events, event)
		}
	}
	return events, nil
}

// StreamFirst 辅助函数 - 获取第一个事件
func StreamFirst(reader *stream.Reader[*session.Event]) (*session.Event, error) {