CoroutineUtils.kt

/**
 * Execute [block] and operate [predicate] on returned value. Each retries can be separated by
 * [delay] if necessary.
 *
 * @param count Number of tries before failing.
 * @param delay Delay between retries
 * @param block Code to execute
 * @param predicate Predicate to execute.
 */
suspend fun <T> retryWithPredicate(
  count: Int = 5,
  delay: Long = 0,
  block: suspend (Int) -> T,
  predicate: suspend (T) -> Boolean
): T {
  for (i in 1..count) {
    count.takeIf { it > 1 }.run { delay(delay) }
    block(i).takeIf { predicate(it) }?.run { return this }
  }

  throw RetriesExceededException()
}

/**
 * Thrown when number of retries has been exceeded.
 */
class RetriesExceededException : Exception()

👍