秤姐打字-pptself

Question

我正在尝试使用新的 Akka Actor API。我想将 Future 的结果通过管道传递给调用它的演员。为此，我使用 pipeToSelf。但是，我收到此错误：

方法 pipeToSelf 的参数不足：（未来：java.util.concurrent.CompletionStage[Value]，applyToResult：akka.japi.function.Function2[Value,Throwable,EmailActor.Command]）单位.

关于如何解决这个问题有什么想法吗？它源自此代码片段。

val emailResult: Future[Unit] = mailer(email)

context.pipeToSelf(emailResult) {
  case Success(_) =>
    EmailSuccess(replyTo)
  case Failure(e) =>
    SendFailed(replyTo)
}

旁注：

消息扩展 Command

Answer 1

您很可能引用了 akka.actor.typed.javadsl.ActorContext 而不是您期望的 akka.actor.typed.scaladsl.ActorContext。检查您的导入

秤姐打字-pptself

Scala Akka Typed - pipeToSelf

scala

akka