Function buildZeroArgAsync

cel/async/async_test.go:43–60

buildZeroArgAsync builds a zero-arity async overload from an option and returns its AsyncOp.

(t *testing.T, opt decls.OverloadOpt)

// buildZeroArgAsync builds a zero-arity async overload from an option and returns its AsyncOp.
func buildZeroArgAsync(t *testing.T, opt decls.OverloadOpt) functions.AsyncOp {
	t.Helper()
	fnDecl, err := decls.NewFunction("fn", decls.Overload("fn_zero", []*types.Type{}, types.IntType, opt))
	if err != nil {
		t.Fatalf("NewFunction() failed: %v", err)
	}
	bindings, err := fnDecl.Bindings()
	if err != nil {
		t.Fatalf("Bindings() failed: %v", err)
	}
	for _, b := range bindings {
		if b.Async != nil {
			return b.Async
		}
	}
	t.Fatal("no async binding produced")
	return nil
}

func TestRetryMultipleAttemptsTimerReset(t *testing.T) {
	var attempts atomic.Int32