Future with delayed execution in a non-blocking style via akka scheduler

DelayedFuture.scala

import akka.actor.Scheduler

import scala.concurrent.duration.FiniteDuration
import scala.concurrent.{ExecutionContext, Future, Promise}

object DelayedFuture {
  def apply[T](scheduler: Scheduler, delay: FiniteDuration)(body: => T)(implicit ec: ExecutionContext): Future[T] = {
    val delayPromise = Promise[Unit]()
    scheduler.scheduleOnce(delay)(delayPromise.success(()))

    delayPromise.future.map { _ => body }
  }
}