Function StreamLast

pkg/agent/streaming.go:205–230

StreamLast 辅助函数 - 获取最后一个事件

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

// StreamLast 辅助函数 - 获取最后一个事件
func StreamLast(reader *stream.Reader[*session.Event]) (*session.Event, error) {
	var lastEvent *session.Event
	var lastErr error

	for {
		event, err := reader.Recv()
		if err != nil {
			if errors.Is(err, io.EOF) {
				break
			}
			lastErr = err
			continue
		}
		if event != nil {
			lastEvent = event
		}
	}

	if lastErr != nil {
		return lastEvent, lastErr
	}
	if lastEvent == nil {
		return nil, errors.New("no events in stream")
	}
	return lastEvent, nil
}

// StreamFilter 辅助函数 - 过滤事件
func StreamFilter(reader *stream.Reader[*session.Event], predicate func(*session.Event) bool) *stream.Reader[*session.Event] {