kotlin - Kotlin 中的管道

Question

来自语言指南：（素数查找器）

fun CoroutineScope.numbersFrom(start: Int) = produce<Int> {
    var x = start
    while (true) send(x++) // infinite stream of integers from start
}

fun CoroutineScope.filter(numbers: ReceiveChannel<Int>, prime: Int) = produce<Int> {
    for (x in numbers) if (x % prime != 0) send(x)
}

    var cur = numbersFrom(2)
    repeat(10) {
    val prime = cur.receive()
    println(prime)
    cur = filter(cur, prime)
    }
    coroutineContext.cancelChildren() // cancel all children to let main finish

过滤器如何获取不是 receiveChannel 对象的参数？？？（来自第二次调用obv）

标签： kotlinchannel

Answer 1

哈哈它是一个receivechannel obj。诡计。