Helper method for akka actor system to keep asking an underlying `service` actor continuously and replying to the original requester upon the underlying request completion.

AskingActor.scala

import akka.actor._
import akka.pattern.ask
import scala.concurrent.duration._
import scala.concurrent.Future
import scala.concurrent.Promise
import scala.concurrent.ExecutionContext

class AskingActor(val service: ActorRef) extends Actor {
  case class SomeCommand(id: String)
  case class SomeEvent(id: String)
  case class ServiceRequest(foo: String)
  import context._

  def receive: Receive = {
    case SomeCommand(id) =>
      val replyTo = sender
      keepAsking(service, ServiceRequest("bar"), 50.millis) foreach { replyTo ! SomeEvent(id) }
  }

  def keepAsking(recepient: ActorRef, msg: Any, every: FiniteDuration = 100.millis): Future[Any] = {
    val p = Promise[Any]()
    val cancel = system.scheduler.schedule(0.millis, every) {
      ask(recepient, msg)(1.hour) foreach { reply => p.trySuccess(reply) }
    }
    val f = p.future
    f.onComplete { reply => cancel.cancel() }
    f
  }
}