Function TestRunUntilEndpointHit_Signal

interactive/interactive_test.go:18–36

(t *testing.T)

)

func TestRunUntilEndpointHit_Signal(t *testing.T) {
	s := make(chan struct{})
	go func() {
		testutil.Ok(t, RunUntilEndpointHit())
		s <- struct{}{}
		close(s)
	}()

	pid := os.Getpid()
	testutil.Ok(t, runutil.Retry(200*time.Millisecond, context.Background().Done(), func() error {
		testutil.Ok(t, syscall.Kill(pid, syscall.SIGHUP))
		select {
		case <-s:
			return nil
		default:
			return errors.New("execution is still stopped")
		}
	}))
}

func TestRunUtilSignal(t *testing.T) {
	s := make(chan struct{})