Say (just an example) I access an api flow that needs to log in to start working with it, how can I catch the NotLoggedIn exception and then retry the original flow?

Take a look at this operator: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/retry.html

So inside the predicate lambda I should subscribe to the login flow?