Propagate KotlinType into create method for coroutines

#KT-27526 Fixed
2018-10-11 17:25:59 +03:00
parent a8abd8cceb
commit 0201694f84
15 changed files with 264 additions and 28 deletions
@@ -0,0 +1,126 @@
+// WITH_COROUTINES
+// WITH_RUNTIME
+// IGNORE_BACKEND: JVM_IR, JS_IR
+
+import helpers.*
+import kotlin.coroutines.*
+import kotlin.coroutines.intrinsics.*
+
+inline class BoxAny(val value: Any?) {
+    val intValue: Int get() = value as Int
+}
+
+inline class BoxInt(val value: Int)
+
+inline class BoxLong(val value: Long)
+
+class EmptyContinuation<T> : Continuation<T> {
+    override val context: CoroutineContext
+        get() = EmptyCoroutineContext
+
+    override fun resumeWith(result: Result<T>) {}
+}
+
+suspend fun foo(block: suspend (BoxAny) -> Unit) {
+    block(BoxAny(1))
+    block.startCoroutineUninterceptedOrReturn(BoxAny(1), EmptyContinuation())
+}
+
+suspend fun fooReceiver(block: suspend BoxAny.() -> Unit) {
+    BoxAny(1).block()
+    block.startCoroutineUninterceptedOrReturn(BoxAny(1), EmptyContinuation())
+}
+
+suspend fun bar(block: suspend (BoxInt) -> Unit) {
+    block(BoxInt(2))
+    block.startCoroutineUninterceptedOrReturn(BoxInt(2), EmptyContinuation())
+}
+
+suspend fun barReceiver(block: suspend BoxInt.() -> Unit) {
+    BoxInt(2).block()
+    block.startCoroutineUninterceptedOrReturn(BoxInt(2), EmptyContinuation())
+}
+
+suspend fun baz(block: suspend (BoxLong) -> Unit) {
+    block(BoxLong(3))
+    block.startCoroutineUninterceptedOrReturn(BoxLong(3), EmptyContinuation())
+}
+
+suspend fun bazReceiver(block: suspend BoxLong.() -> Unit) {
+    BoxLong(3).block()
+    block.startCoroutineUninterceptedOrReturn(BoxLong(3), EmptyContinuation())
+}
+
+suspend fun BoxAny.extension(block: suspend BoxAny.() -> Unit) {
+    this.block()
+    block()
+
+    block.startCoroutineUninterceptedOrReturn(this, EmptyContinuation())
+}
+
+suspend fun BoxInt.extension(block: suspend BoxInt.() -> Unit) {
+    this.block()
+    block()
+
+    block.startCoroutineUninterceptedOrReturn(this, EmptyContinuation())
+}
+
+suspend fun BoxLong.extension(block: suspend BoxLong.() -> Unit) {
+    this.block()
+    block()
+
+    block.startCoroutineUninterceptedOrReturn(this, EmptyContinuation())
+}
+
+fun runBlocking(block: suspend () -> Unit) {
+    block.startCoroutine(object : Continuation<Unit> {
+        override val context: CoroutineContext
+            get() = EmptyCoroutineContext
+
+        override fun resumeWith(result: Result<Unit>) {
+            (block as Function1<Continuation<Unit>, Any?>)(this)
+        }
+    })
+}
+
+fun box(): String {
+    var result = 0
+    runBlocking {
+        foo { boxAny ->
+            result += boxAny.intValue
+        }
+        fooReceiver {
+            result += this.intValue
+        }
+
+        bar { boxInt ->
+            result += boxInt.value
+        }
+        barReceiver {
+            result += value
+        }
+
+        baz { boxLong ->
+            result += boxLong.value.toInt()
+        }
+        bazReceiver {
+            result += this.value.toInt()
+        }
+
+        val b = BoxAny(4)
+        b.extension {
+            result += intValue
+        }
+
+        val bInt = BoxInt(5)
+        BoxInt(5).extension {
+            result += value + bInt.value
+        }
+
+        BoxLong(6).extension {
+            result += value.toInt()
+        }
+    }
+
+    return if (result == 168) "OK" else "Error: $result"
+}