Is there a way to use

retry

based on a valid emitted value and not based on exception occuring? My emitted value looks like this

public sealed class BillingClientState{
        public object Initializing: BillingClientState()
        public data class Available(val client: BillingClient): BillingClientState()
        public object Unavailable: BillingClientState()
        public object Disconnected: BillingClientState()
    }

I want rety when Disconnected is triggered

one option:

.onEach { check(it !is Disconnected) }.retry(...)

Any idea how would limit attempts? I tried using a recursive

retryWhen

but did not work.

should work if you add a counter and guard,

fun <T> Flow<T>.retryWhen(retries: Int = Int.MAX_VALUE, predicate: suspend (T) -> Boolean): Flow<T> {
    require(retries >= 0)
    return if (retries == 0) this else transformWhile {
        if (predicate(it)) {
            emitAll(retryWhen(retries - 1, predicate))
            false
        } else {
            emit(it)
            true
        }
    }
}

Thanks a lot for a quick reply, will try this.