The error message is confusing here as it’s not clear what’s happening. I guess the code is indeed incorrect? Then just the documentation could be improved a little.

suspend fun main() {
    flow {
        flowOf(1).collectLatest { emit(it) }
    }.collect { println(it) }
}

IllegalStateException: Flow invariant is violated

you've truncated the error message, it does explain what's going on:

java.lang.IllegalStateException: Flow invariant is violated:

Emission from another coroutine is detected.

FlowCollector is not thread-safe and concurrent emissions are prohibited.

To mitigate this restriction please use 'channelFlow' builder instead of 'flow'

@ephemient no it doesn’t really explain the reason in this case - even if the mitigation works. At best it presumes some knowledge about the inner workings of

collectLatest

. It’s not clear that

collectLatest

launches multiple coroutines. And it doesn’t do anything concurrently. The explanation at the function that throws the exception only mentions

launch

as an example.

collectLatest has to launch a coroutine so it can be cancelled on the next upstream emission

Yes that’s what I mean. One has to know quite some details before figuring out the cause of the exception. I had that error in rather length Flow implementation. I was puzzled what could possibly cause the error since I didn’t launch any new coroutines to emit from. At least it wasn’t obvious at first. Improving the error message or the documentation can help save developers’ time 🙂