AkkaTypedRateLimiter.scala

class AkkaTypedRateLimiter(actorSystem: ActorSystem[RateLimiterMsg]) 
  extends StrictLogging {
    
  def runLimited[T](f: => Future[T])(implicit ec: ExecutionContext): Future[T] = {
    val p = Promise[T]
    actorSystem ! LazyFuture(() => f.andThen { case r => p.complete(r) }.map(_ => ()))
    p.future
  }
}

object AkkaTypedRateLimiter {
  def create(maxRuns: Int, per: FiniteDuration): AkkaTypedRateLimiter = {
    val behavior = Behaviors.withTimers[RateLimiterMsg] { timer =>
      rateLimit(timer, RateLimiterQueue(maxRuns, per.toMillis))
    }
    new AkkaTypedRateLimiter(ActorSystem(behavior, "rate-limiter"))
  }
}