Function WaitForChannel

rest/utilities_testing_async.go:23–39

(t *testing.T, ch <-chan error, message string)

const TestChannelTimeout = 30 * time.Second

func WaitForChannel(t *testing.T, ch <-chan error, message string) {
	if message != "" {
		log.Printf("[%s] starting wait", message)
		defer func() {
			log.Printf("[%s] completed wait", message)
		}()
	}
	select {
	case err := <-ch:
		if err != nil {
			require.Fail(t, fmt.Sprintf("[%s] channel returned error: %v", message, err))
		}
		return
	case <-time.After(TestChannelTimeout):
		require.Fail(t, fmt.Sprintf("[%s] expected channel message did not arrive in %v", message, TestChannelTimeout))
	}
}

func waitForError(t *testing.T, ch <-chan error, message string) error {
	if message != "" {