You can also have a look at ConflatedBroadcastChannel: <https://kotlin.github.io/kotlinx.coroutines/...

# coroutines

[krotki]

You can also have a look at ConflatedBroadcastChannel: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.experimental.channels/-conflated-broadcast-channel/index.html

[Joe]

Thanks for your help!

[bj0]

looks similar to an extension function i use:

suspend fun <T> BroadcastChannel<T>.waitUntil(value: T): T {
    consume {
        for (element in this)
            if (element == value)
                return value
    }

    throw CancellationException("channel closed before item received")
}

[bj0]

actually yours will spinlock, you probably want to do something about that

[Joe]

But consume will pop the element out of the queue, right?

[Joe]

I’m aware that it could spin forever, but my view was that it was the consumer’s responsibility to timeout or throw it away or whatever.

[bj0]

it's a broadcast channel, there's no problem with popping it out of (your subscription). It wont effect anyone else getting elements.

[bj0]

spinning forever can cause really bad performance or app lockups, you should really avoid it

[Joe]

Both good points, I'll take another look at it. Thanks!