科特林的管道

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对象的参数？？？ （来自第二次通话的观看）

Answer 1

哈哈，它是一个接收通道obj。诡计。