Is there a coroutine function like

singleOrNull()/firstOrNull()

that does not suspend until first item is emitted? My use case:

suspend fun execute(dispatcher: Coroutines.Dispatcher) {
    withContext(dispatcher) {
        // do something that returns result
        // also process outstanding tasks from SharedFlow<() -> Unit>
        outStandingTask.state.singleOrNull()?.invoke() // suspends, so no result is returned
        return result
    }
}

Would a simple Queue fit better?

What type is

outstandingTask.state

?

It's a

SharedFlow<() -> Unit>

Only thing I can think of is add a timeout and then do firstOrNull and handle the timeout. If no one is trying to suspend when getting data from the

state

, then a queue might be a better fit. Polling a flow is uncommon. If you are polling multiple flows, then using channels and a select call might be better.

Thanks that already helps. I know what I have to do now