Package akka.pattern
Interface PipeToSupport
-
public interface PipeToSupport
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static classPipeToSupport.PipeableCompletionStage<T>static classPipeToSupport.PipeableFuture<T>
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <T> PipeToSupport.PipeableFuture<T>pipe(scala.concurrent.Future<T> future, scala.concurrent.ExecutionContext executionContext)Import this implicit conversion to gain thepipeTomethod onFuture:<T> PipeToSupport.PipeableCompletionStage<T>pipeCompletionStage(java.util.concurrent.CompletionStage<T> future, scala.concurrent.ExecutionContext executionContext)Import this implicit conversion to gain thepipeTomethod onFuture:
-
-
-
Method Detail
-
pipe
<T> PipeToSupport.PipeableFuture<T> pipe(scala.concurrent.Future<T> future, scala.concurrent.ExecutionContext executionContext)
Import this implicit conversion to gain thepipeTomethod onFuture:import akka.pattern.pipe // requires implicit ExecutionContext, e.g. by importing `context.dispatcher` inside an Actor Future { doExpensiveCalc() } pipeTo nextActor or pipe(someFuture) to nextActorThe successful result of the future is sent as a message to the recipient, or the failure is sent in a
Status.Failureto the recipient.
-
pipeCompletionStage
<T> PipeToSupport.PipeableCompletionStage<T> pipeCompletionStage(java.util.concurrent.CompletionStage<T> future, scala.concurrent.ExecutionContext executionContext)
Import this implicit conversion to gain thepipeTomethod onFuture:import akka.pattern.pipe // requires implicit ExecutionContext, e.g. by importing `context.dispatcher` inside an Actor Future { doExpensiveCalc() } pipeTo nextActor or pipe(someFuture) to nextActorThe successful result of the future is sent as a message to the recipient, or the failure is sent in a
Status.Failureto the recipient.
-
-