Futures and Resizers

pipeTo.scala

import akka.dispatch.Future
import akka.pattern.pipe
import akka.actor.Actor

case class Work(s: String)
case class Result(s: String)

object MyActor {
  // put here to avoid closing over actor’s state
  def doWork(work: String): String = {
    // this takes very long
    "hello " + work
  }
}

class MyActor extends Actor {
  import context.dispatcher
  def receive = {
    case Work(w) =>
      Future { Result(MyActor.doWork(w)) } pipeTo sender
  }
}

resizer.scala

import akka.actor.{ Props, ActorSystem }
import akka.routing.{ RoundRobinRouter, DefaultResizer }

object Demo {
  val system = ActorSystem()
  val flexibleRouter = system.actorOf(Props.empty.withRouter(
    RoundRobinRouter(resizer = Some(DefaultResizer(
      lowerBound = 1, upperBound = 10)))))
}