I wrote this simple extension function to endlessl...

# coroutines

[Drew Hamilton]

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?

[Dico]

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.

[Dominaezzz]

Channels don't have subscribers.

[Drew Hamilton]

OH. It clicks now. Thanks y’all!