Function TestConcurrentEvalAsyncObserver

cel/program_async_test.go:575–601

(t *testing.T)

}

func TestConcurrentEvalAsyncObserver(t *testing.T) {
	obs := &countingObserver{}
	prg := mustProgram(t, `async_func(10) + async_func(20)`,
		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 {
					time.Sleep(5 * time.Millisecond)
					return args[0]
				}),
			),
		),
		cel.AsyncCallObserver(obs),
	)
	res := awaitEval(t, prg, context.Background(), cel.NoVars())
	if res.Err != nil {
		t.Fatalf("ConcurrentEval() error: %v", res.Err)
	}
	if res.Val.Equal(types.Int(30)) != types.True {
		t.Errorf("ConcurrentEval() = %v, want 30", res.Val)
	}
	if got := obs.started.Load(); got != 2 {
		t.Errorf("OnCallStarted count = %d, want 2", got)
	}
	if got := obs.finished.Load(); got != 2 {
		t.Errorf("OnCallFinished count = %d, want 2", got)
	}
}

func TestConcurrentEvalProgramThreadSafety(t *testing.T) {
	prg := mustProgram(t, `async_func(x) + 1`,