diff --git a/pkg/util/async/bounded_frequency_runner_test.go b/pkg/util/async/bounded_frequency_runner_test.go index 1f9791af878..333adabcf79 100644 --- a/pkg/util/async/bounded_frequency_runner_test.go +++ b/pkg/util/async/bounded_frequency_runner_test.go @@ -277,6 +277,9 @@ func Test_BoundedFrequencyRunnerNoBurst(t *testing.T) { // Clean up. stop <- struct{}{} + // a message is sent to time.updated in func Stop() at the end of the child goroutine + // to terminate the child, a receive on time.updated is needed here + <-timer.updated } func Test_BoundedFrequencyRunnerBurst(t *testing.T) { @@ -358,6 +361,9 @@ func Test_BoundedFrequencyRunnerBurst(t *testing.T) { // Clean up. stop <- struct{}{} + // a message is sent to time.updated in func Stop() at the end of the child goroutine + // to terminate the child, a receive on time.updated is needed here + <-timer.updated } func Test_BoundedFrequencyRunnerRetryAfter(t *testing.T) { @@ -441,4 +447,7 @@ func Test_BoundedFrequencyRunnerRetryAfter(t *testing.T) { // Clean up. stop <- struct{}{} + // a message is sent to time.updated in func Stop() at the end of the child goroutine + // to terminate the child, a receive on time.updated is needed here + <-timer.updated }