Import this implicit conversion to gain the pipeTo
method on scala.concurrent.Future:
Import this implicit conversion to gain the pipeTo
method on scala.concurrent.Future:
import akka.pattern.pipe
Future { doExpensiveCalc() } pipeTo nextActor
or
pipe(someFuture) to nextActor
The successful result of the future is sent as a message to the recipient, or the failure is sent in a akka.actor.Status.Failure to the recipient.