Function waitRedshiftSubResult

tests/redshift_surface_test.go:208–220

(t *testing.T, m *core.Member, timeout time.Duration)

}

func waitRedshiftSubResult(t *testing.T, m *core.Member, timeout time.Duration) *core.Result {
	t.Helper()
	select {
	case msg := <-m.Result:
		if len(msg.Errors) != 0 {
			t.Fatalf("subscription returned errors: %+v", msg.Errors)
		}
		return msg
	case <-time.After(timeout):
		t.Fatalf("timed out waiting for redshift subscription result after %s", timeout)
	}
	return nil
}

func assertNoRedshiftSubResult(t *testing.T, m *core.Member, timeout time.Duration) {
	t.Helper()