Function delayThreadStart

pubsub/util.go:25–34

(t *testing.T)

}

func delayThreadStart(t *testing.T) time.Duration {
	if val := os.Getenv("TEST_DELAY_THREAD_START"); val != "" {
		d, err := time.ParseDuration(val)
		require.NoError(t, err)

		return d
	}

	return defaultDelayThreadStart
}