Fixed testdata.

This commit is contained in:
Stanislav Erokhin
2016-12-16 00:56:13 +03:00
parent ab53978793
commit d7566d84d0
18 changed files with 116 additions and 142 deletions
+2 -1
View File
@@ -2,6 +2,7 @@
// FULL_JDK
import java.util.concurrent.CompletableFuture
import kotlin.coroutines.*
fun foo(): CompletableFuture<String> = CompletableFuture.supplyAsync { "foo" }
fun bar(v: String): CompletableFuture<String> = CompletableFuture.supplyAsync { "bar with $v" }
@@ -43,7 +44,7 @@ fun box(): String {
// LIBRARY CODE
fun <T> async(c: @Suspend() (() -> T)): CompletableFuture<T> {
fun <T> async(c: suspend () -> T): CompletableFuture<T> {
val future = CompletableFuture<T>()
c.startCoroutine(object : Continuation<T> {
override fun resume(data: T) {
+3 -2
View File
@@ -2,6 +2,7 @@
// FULL_JDK
import java.util.concurrent.CompletableFuture
import kotlin.coroutines.*
fun exception(v: String): CompletableFuture<String> = CompletableFuture.supplyAsync { throw RuntimeException(v) }
@@ -40,9 +41,9 @@ fun box(): String {
return "No exception"
}
fun <T> async(c: @Suspend() (() -> T)): CompletableFuture<T> {
fun <T> async(c: suspend () -> T): CompletableFuture<T> {
val future = CompletableFuture<T>()
c.startContinuation(object : Continuation<T> {
c.startCoroutine(object : Continuation<T> {
override fun resume(data: T) {
future.complete(data)
}