Using pipeline pattern with Kotlin channels

pipeline2.kt

package app

import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.channels.ReceiveChannel
import kotlinx.coroutines.channels.consumeEach
import kotlinx.coroutines.channels.produce
import kotlinx.coroutines.runBlocking


fun main() = runBlocking {
    sq(gen(listOf(1, 2, 3, 4, 5))).consumeEach { println(it) }
}

private fun CoroutineScope.gen(nums: List<Int>) = produce {
    nums.forEach { send(it) }
}

private fun CoroutineScope.sq(input: ReceiveChannel<Int>) = produce {
    input.consumeEach { send(it * it) }
}