Function TestContextScheduler

context_test.go:1272–1314

(t *testing.T)

}

func TestContextScheduler(t *testing.T) {
	useStableOwnerHooksForLegacySubtests(t)

	rt := NewRuntime()
	defer rt.Close()
	ctx := rt.NewContext()
	defer ctx.Close()

	t.Run("LoopProcessesScheduledJobs", func(t *testing.T) {
		results := make(chan struct {
			sum int32
			err error
		}, 1)

		require.True(t, ctx.Schedule(func(inner *Context) {
			val := inner.Eval(`40 + 2`)
			defer val.Free()

			if val.IsException() {
				results <- struct {
					sum int32
					err error
				}{err: inner.Exception()}
				return
			}

			results <- struct {
				sum int32
				err error
			}{sum: int32(val.ToInt32())}
		}))

		ctx.Loop()

		select {
		case res := <-results:
			require.NoError(t, res.err)
			require.Equal(t, int32(42), res.sum)
		case <-time.After(200 * time.Millisecond):
			t.Fatal("scheduled job was not executed")
		}
	})
}

func TestContextInternalsCoverage(t *testing.T) {
	t.Run("ScheduleEdgeCases", func(t *testing.T) {