Skip to content

Commit 040657f

Browse files
committed
replace wait loop with testify.Eventually
1 parent 25adc20 commit 040657f

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
@@ -437,20 +437,9 @@ force_inotify: true`, testPattern),
437437
require.NoError(t, err, "could not create test file")
438438

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

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

0 commit comments

Comments
 (0)