A modern programming language that makes developers happier.

kotlinlang

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>

looks similar to an extension function i use:
```
suspend fun &lt;T&gt; BroadcastChannel&lt;T&gt;.waitUntil(value: T): T {
    consume {
        for (element in this)
            if (element == value)
                return value
    }

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

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

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

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.

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

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

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