我正在尝试使用新的Akka Actor API。我想将Future的结果管道传递给调用它的参与者。我用的是pipeToSelf。然而，我得到这个错误:
方法pipeToSelf没有足够的参数:(future: java.util.concurrent。CompletionStage[Value]， applyToResult: akka.japi.function.Function2[Value,Throwable,EmailActor.Command])Unit.
对于如何解决这个问题有什么想法吗?它是由这个代码片段产生的。
val emailResult: Future[Unit] = mailer(email)
context.pipeToSelf(emailResult) {
case Success(_) =>
EmailSuccess(replyTo)
case Failure(e) =>
SendFailed(replyTo)
}
指出:
- 消息扩展
Command
您很可能引用akka.actor.typed.javadsl.ActorContext而不是您期望的akka.actor.typed.scaladsl.ActorContext。检查您的导入