We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d7f61bf commit 3efb516Copy full SHA for 3efb516
pkg/controller/priorityqueue/priorityqueue_test.go
@@ -771,13 +771,7 @@ func TesWhenAddingMultipleItemsWithRatelimitTrueTheyDontAffectEachOther(t *testi
771
q.rateLimiter = workqueue.NewTypedItemExponentialFailureRateLimiter[string](5*time.Millisecond, 1000*time.Second)
772
originalTick := q.tick
773
q.tick = func(d time.Duration) <-chan time.Time {
774
- done := make(chan struct{})
775
- go func() {
776
- defer close(done)
777
-
778
- g.Expect(d).To(Or(Equal(5*time.Millisecond), Equal(635*time.Millisecond)))
779
- }()
780
- <-done
+ g.Expect(d).To(Or(Equal(5*time.Millisecond), Equal(635*time.Millisecond)))
781
return originalTick(d)
782
}
783
0 commit comments