forked from Kotlin/kotlinx.coroutines
-
Notifications
You must be signed in to change notification settings - Fork 0
/
WorkerTest.kt
37 lines (32 loc) · 901 Bytes
/
WorkerTest.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
/*
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/
package kotlinx.coroutines
import kotlin.coroutines.*
import kotlin.native.concurrent.*
import kotlin.test.*
class WorkerTest : TestBase() {
@Test
fun testLaunchInWorker() {
val worker = Worker.start()
worker.execute(TransferMode.SAFE, { }) {
runBlocking {
launch { }.join()
delay(1)
}
}.result
worker.requestTermination()
}
@Test
fun testLaunchInWorkerTroughGlobalScope() {
val worker = Worker.start()
worker.execute(TransferMode.SAFE, { }) {
runBlocking {
CoroutineScope(EmptyCoroutineContext).launch {
delay(1)
}.join()
}
}.result
worker.requestTermination()
}
}