Spill stack before analyzing it when looking for non-inline suspend lambda
parameters of inline function. Otherwise, it leads to AnalyzerException, when inlined lambda contains try-catch block. The reason is simple: in try block, we leave some variables on stack, while on catch block the stack is empty. Spilling the variables before try block does the trick. #KT-34708 Fixed
This commit is contained in:
@@ -0,0 +1,67 @@
|
||||
// FILE: inlined.kt
|
||||
// COMMON_COROUTINES_TEST
|
||||
// WITH_RUNTIME
|
||||
// WITH_COROUTINES
|
||||
// NO_CHECK_LAMBDA_INLINING
|
||||
|
||||
interface Flow<out T> {
|
||||
suspend fun collect(collector: FlowCollector<T>)
|
||||
}
|
||||
|
||||
interface FlowCollector<in T> {
|
||||
suspend fun emit(value: T)
|
||||
}
|
||||
|
||||
inline suspend fun <T> Flow<T>.collect(crossinline action: suspend (value: T) -> Unit): Unit =
|
||||
collect(object : FlowCollector<T> {
|
||||
override suspend fun emit(value: T) = action(value)
|
||||
})
|
||||
|
||||
inline fun <T, R> Flow<T>.transform(
|
||||
crossinline transform: suspend FlowCollector<R>.(value: T) -> Unit
|
||||
): Flow<R> = flow {
|
||||
collect { value ->
|
||||
return@collect transform(value)
|
||||
}
|
||||
}
|
||||
|
||||
inline fun <T, R> Flow<T>.map(crossinline transform: suspend (value: T) -> R): Flow<R> = transform { value ->
|
||||
return@transform emit(transform(value))
|
||||
}
|
||||
|
||||
public fun <T> flow(block: suspend FlowCollector<T>.() -> Unit): Flow<T> = SafeFlow(block)
|
||||
|
||||
private class SafeFlow<T>(private val block: suspend FlowCollector<T>.() -> Unit) : Flow<T> {
|
||||
override suspend fun collect(collector: FlowCollector<T>) {
|
||||
collector.block()
|
||||
}
|
||||
}
|
||||
|
||||
// FILE: inlineSite.kt
|
||||
// COMMON_COROUTINES_TEST
|
||||
import COROUTINES_PACKAGE.*
|
||||
import helpers.*
|
||||
|
||||
fun Flow<String>.abc() = map { line ->
|
||||
try {
|
||||
line
|
||||
} catch (e: Exception) {
|
||||
e.message!!
|
||||
}
|
||||
}
|
||||
|
||||
fun builder(c: suspend () -> Unit) {
|
||||
c.startCoroutine(EmptyContinuation)
|
||||
}
|
||||
|
||||
fun box(): String {
|
||||
var res = "FAIL"
|
||||
builder {
|
||||
flow<String> {
|
||||
emit("OK")
|
||||
}.abc().collect {
|
||||
res = it
|
||||
}
|
||||
}
|
||||
return res
|
||||
}
|
||||
Reference in New Issue
Block a user