|
1 | 1 | package io.sentry |
2 | 2 |
|
3 | 3 | import io.sentry.test.getProperty |
| 4 | +import java.util.concurrent.BlockingQueue |
| 5 | +import java.util.concurrent.Callable |
| 6 | +import java.util.concurrent.CancellationException |
4 | 7 | import java.util.concurrent.LinkedBlockingQueue |
5 | 8 | import java.util.concurrent.ScheduledThreadPoolExecutor |
6 | 9 | import java.util.concurrent.TimeUnit |
7 | 10 | import java.util.concurrent.atomic.AtomicBoolean |
8 | 11 | import kotlin.test.Test |
9 | 12 | import kotlin.test.assertEquals |
| 13 | +import kotlin.test.assertFailsWith |
10 | 14 | import kotlin.test.assertFalse |
11 | 15 | import kotlin.test.assertTrue |
12 | 16 | import org.awaitility.kotlin.await |
13 | 17 | import org.mockito.kotlin.any |
14 | 18 | import org.mockito.kotlin.doReturn |
15 | 19 | import org.mockito.kotlin.mock |
16 | 20 | import org.mockito.kotlin.never |
17 | | -import org.mockito.kotlin.spy |
18 | 21 | import org.mockito.kotlin.verify |
19 | 22 | import org.mockito.kotlin.whenever |
20 | | -import java.util.concurrent.BlockingQueue |
21 | | -import java.util.concurrent.Callable |
22 | | -import java.util.concurrent.CancellationException |
23 | | -import kotlin.test.assertFailsWith |
24 | 23 |
|
25 | 24 | class SentryExecutorServiceTest { |
26 | 25 | @Test |
@@ -110,6 +109,7 @@ class SentryExecutorServiceTest { |
110 | 109 | whenever(executor.isShutdown).thenReturn(false) |
111 | 110 | assertFalse(sentryExecutor.isClosed) |
112 | 111 | } |
| 112 | + |
113 | 113 | @Test |
114 | 114 | fun `SentryExecutorService submit runnable returns cancelled future when queue size exceeds limit`() { |
115 | 115 | val queue = mock<BlockingQueue<Runnable>>() |
|
0 commit comments