In a flow why doesn't catch capture errors for an onEach?

# coroutines

[Luis Munoz]

In a flow why doesn't catch capture errors for an onEach?

[Luis Munoz]

suspend fun myErrorMethod(value: String) {
        throw RuntimeException("myErrorMethod $value")
    }

val scope = CoroutineScope(newFixedThreadPoolContext(2, "tPool") )

   val job = flow {
        repeat(3) {
            emit(it)
        }
        myErrorMethod("flow")
        emit(1)
    }.catch { e ->
        println("error ${e.message}")
        emit(11)
    }
    .onEach {
        println(it)
        myErrorMethod("flow")
    }
    .catch { e ->
        println("error ${e.message}")
        emit(12)
    }
    .onCompletion {
        println("on Complete")
        emit(10)
    }
    .launchIn(scope)

[Luis Munoz]

0
error myErrorMethod flow
on Complete

[taer]

I was curious, so I played w/ your code some(mostly differentiating the myError calls and the catches

[taer]

https://pl.kotl.in/bcfBLq8ai

[taer]

here

flow {
        repeat(3) {
            emit(it)
        }
        myErrorMethod("flow")
        emit(1)

That myErrorMethod("flow" never gets called.

You emit 0 from the first loop. thus the first catch doesn't see it. the first onEach sees the 0, prints it, and then throws.the second catch is what is printing your message. It recovers the flow and emits 12. Then the oncpomplete emits the 10

[Luis Munoz]

oh oops you are right, thank you