-
Notifications
You must be signed in to change notification settings - Fork 1.8k
/
FutureAsDeferredUnhandledCompletionExceptionTest.kt
46 lines (38 loc) · 1.51 KB
/
FutureAsDeferredUnhandledCompletionExceptionTest.kt
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
/*
* Copyright 2016-2021 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/
package kotlinx.coroutines.guava
import com.google.common.util.concurrent.*
import kotlinx.coroutines.*
import org.junit.*
import org.junit.Test
import kotlin.test.*
class FutureAsDeferredUnhandledCompletionExceptionTest : TestBase() {
// This is a separate test in order to avoid interference with uncaught exception handlers in other tests
private val exceptionHandler = Thread.getDefaultUncaughtExceptionHandler()
private lateinit var caughtException: Throwable
@Before
fun setUp() {
Thread.setDefaultUncaughtExceptionHandler { _, e -> caughtException = e }
}
@After
fun tearDown() {
Thread.setDefaultUncaughtExceptionHandler(exceptionHandler)
}
@Test
fun testLostExceptionOnSuccess() = runTest {
val future = SettableFuture.create<Int>()
val deferred = future.asDeferred()
deferred.invokeOnCompletion { throw TestException() }
future.set(1)
assertTrue { caughtException is CompletionHandlerException && caughtException.cause is TestException }
}
@Test
fun testLostExceptionOnFailure() = runTest {
val future = SettableFuture.create<Int>()
val deferred = future.asDeferred()
deferred.invokeOnCompletion { throw TestException() }
future.setException(TestException2())
assertTrue { caughtException is CompletionHandlerException && caughtException.cause is TestException }
}
}