Igor Laevsky
25 lines
521 B
Kotlin
Vendored
25 lines
521 B
Kotlin
Vendored
// IGNORE_BACKEND: WASM
|
|
// WASM_MUTE_REASON: COROUTINES
|
|
|
|
// WITH_RUNTIME
|
|
|
|
import kotlin.experimental.ExperimentalTypeInference
|
|
|
|
interface SendChannel<in T> {
|
|
suspend fun send(value: T)
|
|
}
|
|
|
|
@OptIn(ExperimentalTypeInference::class)
|
|
public fun <T> flux(@BuilderInference block: suspend SendChannel<T>.() -> Unit) {}
|
|
|
|
suspend inline fun <T> T.collect(action: (T) -> Unit) { action(this) }
|
|
|
|
fun test() {
|
|
flux {
|
|
var result = ""
|
|
"OK".collect { result += it }
|
|
send(result)
|
|
}
|
|
}
|
|
|
|
fun box() = "OK" |