Is there a coroutine function like `singleOrNull()/firstOrNull()` that does not suspend until first ...

# coroutines

[Lilly]

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?

[mkrussel]

What type is outstandingTask.state ?

[Lilly]

It's a SharedFlow<() -> Unit>

[mkrussel]

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.

[Lilly]

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