Function TestCheckpoint_WaitComplete

agent/checkpoint_internal_test.go:36–49

(t *testing.T)

}

func TestCheckpoint_WaitComplete(t *testing.T) {
	t.Parallel()
	logger := testutil.Logger(t)
	ctx := testutil.Context(t, testutil.WaitShort)
	uut := newCheckpoint(logger)
	err := xerrors.New("test")
	errCh := make(chan error, 1)
	go func() {
		errCh <- uut.wait(ctx)
	}()
	uut.complete(err)
	got := testutil.TryReceive(ctx, t, errCh)
	require.Equal(t, err, got)
}