Акка будущее с пайпо - PullRequest
Новая
       4

Акка будущее с пайпо

0 голосов
/ 09 марта 2012

Я получил следующий код 

def receive {

case CategoryData(links, hasNextPage) =>
  val scrapCompany = links.map( url => (router ? Scrap(url, Company) ).mapTo[Store] )
  val futureResult = Future.sequence(scrapCompany)
  futureResult onComplete {
    case Right(items) =>
      println(items.length)
    case Left(failure) =>
      println(failure)
  }
  futureResult.pipeTo(router)

Но я получаю только совпадение при неудаче, право onComplete (элементы) никогда не доступно. pipeTo также не отправляет фьючерсы на другой маршрутизатор.

Имейте в виду, что этот код находится внутри другого актера.

...