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)

0
error myErrorMethod flow
on Complete

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

myErrorMethod("flow"