waitForCond.scala

/*
 * check a condition asynchronously until it's true and then do another thing
 */

def checkCond: Future[Boolean] = ???
def doThing[T]: Future[T] = ???
implicit val timer = DefaultTimer.twitter

def untilCondition(backoff: Stream[Duration]): Future[Unit] =
  checkCond.flatMap {
    case false =>
      backoff match {
        case wait #:: backoff =>
          Future.sleep(wait).before(untilCondition(backoff))
        case _ => Future.exception(new Exception("I fucked up"))
      }
    case true => Future.Unit
  }

val thing: Future[T] = untilCondition(Backoff.exponentialJittered(0.millis, 1.minute)).before(doThing)