File tree Expand file tree Collapse file tree 1 file changed +8
-6
lines changed
sentry/src/test/java/io/sentry/transport Expand file tree Collapse file tree 1 file changed +8
-6
lines changed Original file line number Diff line number Diff line change @@ -39,6 +39,8 @@ import org.mockito.kotlin.verifyNoMoreInteractions
3939import org.mockito.kotlin.whenever
4040import java.io.File
4141import java.util.UUID
42+ import java.util.concurrent.CountDownLatch
43+ import java.util.concurrent.TimeUnit
4244import java.util.concurrent.atomic.AtomicBoolean
4345import kotlin.test.Test
4446import kotlin.test.assertEquals
@@ -363,18 +365,18 @@ class RateLimiterTest {
363365 val rateLimiter = fixture.getSUT()
364366 whenever(fixture.currentDateProvider.currentTimeMillis).thenReturn(0 , 1 , 2001 )
365367
366- val applied = AtomicBoolean (true )
368+ val applied = CountDownLatch (1 )
369+ var activeForReplay = false
367370 rateLimiter.addRateLimitObserver {
368- applied.set(rateLimiter.isActiveForCategory(Replay ))
371+ applied.countDown()
372+ activeForReplay = rateLimiter.isActiveForCategory(Replay )
369373 }
370374
371375 rateLimiter.updateRetryAfterLimits(" 1:replay:key" , null , 1 )
372376 rateLimiter.close()
373377
374378 // If rate limit didn't already change, wait for 1.5s to ensure the timer has run after 1s
375- if (! applied.get()) {
376- await.untilTrue(applied)
377- }
378- assertTrue(applied.get())
379+ applied.await(2 , TimeUnit .SECONDS )
380+ assertTrue(activeForReplay)
379381 }
380382}
You can’t perform that action at this time.
0 commit comments