Method loadNthValue

dagql/server.go:1219–1251

(
	ctx context.Context,
	parent AnyResult,
	nth int,
	nullAsError bool,
)

}

func (s *Server) loadNthValue(
	ctx context.Context,
	parent AnyResult,
	nth int,
	nullAsError bool,
) (AnyResult, error) {
	if parent == nil {
		if nullAsError {
			return nil, fmt.Errorf("item %d is null from enumerable", nth)
		}
		return nil, nil
	}

	res, err := parent.NthValue(ctx, nth)
	if err != nil {
		return nil, fmt.Errorf("nth %d: %w", nth, err)
	}
	if res == nil {
		if nullAsError {
			return nil, fmt.Errorf("item %d is null from enumerable", nth)
		}
		return nil, nil
	}

	res, ok := res.DerefValue()
	if !ok || res == nil {
		if nullAsError {
			return nil, fmt.Errorf("item %d is null from enumerable", nth)
		}
		return nil, nil
	}
	return res, nil
}

func (s *Server) LoadType(ctx context.Context, id *call.ID) (_ AnyResult, rerr error) {
	ctx = srvToContext(ctx, s)