summaryrefslogtreecommitdiff
path: root/internal/eventloop_commresolver_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/eventloop_commresolver_test.go')
-rw-r--r--internal/eventloop_commresolver_test.go11
1 files changed, 8 insertions, 3 deletions
diff --git a/internal/eventloop_commresolver_test.go b/internal/eventloop_commresolver_test.go
index d04a05f..4d3b193 100644
--- a/internal/eventloop_commresolver_test.go
+++ b/internal/eventloop_commresolver_test.go
@@ -241,14 +241,19 @@ func waitForWaitGroup(t *testing.T, wg *sync.WaitGroup, timeout time.Duration) {
func waitForCondition(t *testing.T, timeout time.Duration, message string, fn func() bool) {
t.Helper()
- deadline := time.Now().Add(timeout)
+ timer := time.NewTimer(timeout)
+ ticker := time.NewTicker(10 * time.Millisecond)
+ defer timer.Stop()
+ defer ticker.Stop()
+
for {
if fn() {
return
}
- if time.Now().After(deadline) {
+ select {
+ case <-timer.C:
t.Fatal(message)
+ case <-ticker.C:
}
- time.Sleep(10 * time.Millisecond)
}
}