Function waitForMeasure

routing/datasource_test.go:809–830

(t *testing.T, m *metricstest.MockMetrics, key string)

}

func waitForMeasure(t *testing.T, m *metricstest.MockMetrics, key string) {
	t.Helper()
	timeout := time.After(time.Second)
	ticker := time.NewTicker(time.Millisecond)
	defer ticker.Stop()

	for {
		found := false
		m.WithMeasures(func(measures map[string][]time.Duration) {
			_, found = measures[key]
		})
		if found {
			return
		}

		select {
		case <-timeout:
			t.Fatalf("timed out waiting for measure %q", key)
		case <-ticker.C:
		}
	}
}