Added tests on workers's bridges

This commit is contained in:
Igor Chevdar
2017-12-05 18:08:51 +03:00
committed by Igor Chevdar
parent 8df6ff5215
commit 86e221ed58
5 changed files with 92 additions and 0 deletions
@@ -0,0 +1,17 @@
package runtime.workers.worker4
import kotlin.test.*
import konan.worker.*
@Test fun runTest() {
val worker = startWorker()
val future = worker.schedule(TransferMode.CHECKED, { 41 }) {
input -> input + 1
}
future.consume {
result -> println("Got $result")
}
worker.requestTermination().consume { _ -> }
println("OK")
}
@@ -0,0 +1,17 @@
package runtime.workers.worker5
import kotlin.test.*
import konan.worker.*
@Test fun runTest() {
val worker = startWorker()
val future = worker.schedule(TransferMode.CHECKED, { "zzz".shallowCopy() }) {
input -> input.length
}
future.consume {
result -> println("Got $result")
}
worker.requestTermination().consume { _ -> }
println("OK")
}
@@ -0,0 +1,17 @@
package runtime.workers.worker6
import kotlin.test.*
import konan.worker.*
@Test fun runTest() {
val worker = startWorker()
val future = worker.schedule(TransferMode.CHECKED, { 42 }) {
input -> input.toString()
}
future.consume {
result -> println("Got $result")
}
worker.requestTermination().consume { _ -> }
println("OK")
}
@@ -0,0 +1,17 @@
package runtime.workers.worker7
import kotlin.test.*
import konan.worker.*
@Test fun runTest() {
val worker = startWorker()
val future = worker.schedule(TransferMode.CHECKED, { "Input".shallowCopy() }) {
input -> println(input)
}
future.consume {
result -> println("Got $result")
}
worker.requestTermination().consume { _ -> }
println("OK")
}