Asynchronous retry for Future in Scala

Retry.sc

import scala.concurrent.duration._
import scala.concurrent.{Await, Future}
import scala.concurrent.duration.FiniteDuration
import scala.util.control.NonFatal
import scala.concurrent.ExecutionContext.Implicits.global

def foo(): Future[Unit] = if(Math.random() >= 1/3) Future.failed(new RuntimeException("")) else Future.successful(())

def retry[T](retries: Int, delay: FiniteDuration)(fn: => Future[T]): Future[T] = {
  fn recoverWith {
    case NonFatal(_) if retries > 0 =>
      println(s"Retry($retries) failed")
      Thread.sleep(delay.toMillis)
      retry(retries - 1, delay)(fn)
      
    case ex => Future.failed(ex)
  }
}

Await.result(
retry(3, 1.seconds) {
  foo()
}, Duration.Inf)