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

• 方法pipeToSelf的参数不足：（未来：java.util.concurrent.完成阶段[值]，应用于结果：函数2 [值，可引发，电子邮件执行元。命令]）单元。*

如何解决这个问题有什么想法吗？它是由这个代码片段产生的。

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

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

附注：

• 消息扩展Command