Function TestConcurrentEvalPreCanceledContext

cel/program_async_test.go:640–656

(t *testing.T)

}

func TestConcurrentEvalPreCanceledContext(t *testing.T) {
	prg := mustProgram(t, `async_func(42)`,
		cel.Function("async_func",
			cel.Overload("async_func_int", []*cel.Type{cel.IntType}, cel.IntType,
				cel.AsyncBinding(func(ctx context.Context, args ...ref.Val) ref.Val {
					return args[0]
				}),
			),
		),
	)
	ctx, cancel := context.WithCancel(context.Background())
	cancel()
	res := <-prg.ConcurrentEval(ctx, cel.NoVars())
	if res.Err == nil || !errors.Is(res.Err, context.Canceled) {
		t.Errorf("ConcurrentEval() on pre-canceled context = %v, want context.Canceled", res.Err)
	}
}

func TestSyncEvalRejectsAsyncBeforeEvaluating(t *testing.T) {
	// The async guard must fire at the entry point, before any evaluation: the async function