I wrote this simple extension function to endlessly subscribe to a channel (the subscriber’s scope is always <= the sender’s scope):

internal suspend fun <E> ReceiveChannel<E>.forEach(action: (E) -> Unit) {
    val iterator = iterator()
    while (iterator.hasNext())
        action.invoke(iterator.next())
}

I was surprised that such an extension didn’t already exist—things like

consumeEach

only consume existing items in the Channel and then cancel. Am I either missing a function that does what I want, or missing a reason that I shouldn’t do this?

consumeEach

is intended to be used as the sole consumer of a channel. there is little wrong with

for (item in channel){}

and your code is doing exactly that but without syntactic sugar.

Channels don't have subscribers.

OH. It clicks now. Thanks y’all!