Is the a way to resume a flow on error?

fun main() = runBlocking<Unit> {
    emit()
        .onEach {
            if (it == 5) error("oof! some random error occurred.")
            println(it)
        }.catch { println("some error occurred") }
        .collect()
}


fun emit() = flow {
    for (i in 1..10) {
        emit(i)
    }
}

This will print "1 2 3 4" and stop. I'd like to print every number except number 5. (I'm doing this to simulate a random error, i know that in this specific case i could filter out the number 5).

Restart, yes, resume, no. By the time you receive the exception, the state of the flow was already torn down. There's nowhere to resume from.

humm, that's unfortunate. I'll try another aproach. Thanks

I think so? Sorry, I'm not sure of the specific operator function but I'm going by how flow itself works 🙂 once

.collect

resumes with an exception all of the associated state from that collection is gone

oh i see. i'm creating a flow of possibly infinite events, so it's on a

while(true)

loop. So i think that the retry operator is good enough to restart the loop. Thanks again

FWIW: Sounds like you really want to use

SharedFlow

or

StateFlow