Akka类型相当于pipeto是什么？

Question

import akka.pattern.pipe
val horseList : Future[Seq[Horse]] = horseRepository.listHorses(...)
horseList pipeTo sender()

val behaviour : Behavior[ListHorses] = Behaviors.receive { 
    (ctx,msg) => msg match {
        case ListHorses(replyTo) => 
            val horseListF : Future[Seq[Horse]] = horseRepository.listHorses(...)
            // -> how do I make horseListF's content end up at replyTo? <-
            Behaviors.same
    }
}

我该怎么做？

Answer 1

在Akka 2.5.22（可能更早）中有上下文。pipetoSelf:

  def pipeToSelf[Value](future: Future[Value])(mapResult: Try[Value] => T): Unit

您仍然必须为success和failure提供模式匹配，在我的代码中，我使用以下内容减少了这种匹配：

def mapPipe[A, T](success: A => T, failure: Throwable => T): Try[A] => T = {
  case Success(value) => success(value)
  case Failure(e) => failure(e)
}

导致如下调用：

case class Horses(horses: Seq[Horse]) extends Command
case class HorseFailure(e: Throwable) extends Command

...

context.pipeToSelf(horseList) {
  mapPipe(Horses,HorseFailure)
}