Skip to content

Commit b3e4a49

Browse files
committed
replace wait loop with testify.Eventually
1 parent 34f4392 commit b3e4a49

File tree

1 file changed

+3
-14
lines changed

1 file changed

+3
-14
lines changed

pkg/acquisition/modules/file/file_test.go

Lines changed: 3 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -433,20 +433,9 @@ force_inotify: true`, testPattern),
433433
require.NoError(t, err, "could not create test file")
434434

435435
// wait for the file to be tailed
436-
waitingForTail := true
437-
for waitingForTail {
438-
select {
439-
case <-time.After(2 * time.Second):
440-
t.Fatal("Timeout waiting for file to be tailed")
441-
default:
442-
if !f.IsTailing(streamLogFile) {
443-
time.Sleep(50 * time.Millisecond)
444-
continue
445-
}
446-
447-
waitingForTail = false
448-
}
449-
}
436+
require.Eventually(t, func() bool {
437+
return f.IsTailing(streamLogFile)
438+
}, 5*time.Second, 50 * time.Millisecond, "Timeout waiting for %q to be tailed", streamLogFile)
450439

451440
for i := range 5 {
452441
_, err = fmt.Fprintf(fd, "%d\n", i)

0 commit comments

Comments
 (0)