Package akka.pattern
Interface PipeToSupport
-
public interface PipeToSupport
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
PipeToSupport.PipeableCompletionStage<T>
static class
PipeToSupport.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 thepipeTo
method onFuture
:<T> PipeToSupport.PipeableCompletionStage<T>
pipeCompletionStage(java.util.concurrent.CompletionStage<T> future, scala.concurrent.ExecutionContext executionContext)
Import this implicit conversion to gain thepipeTo
method onFuture
:
-
-
-
Method Detail
-
pipe
<T> PipeToSupport.PipeableFuture<T> pipe(scala.concurrent.Future<T> future, scala.concurrent.ExecutionContext executionContext)
Import this implicit conversion to gain thepipeTo
method 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 nextActor
The successful result of the future is sent as a message to the recipient, or the failure is sent in a
Status.Failure
to the recipient.
-
pipeCompletionStage
<T> PipeToSupport.PipeableCompletionStage<T> pipeCompletionStage(java.util.concurrent.CompletionStage<T> future, scala.concurrent.ExecutionContext executionContext)
Import this implicit conversion to gain thepipeTo
method 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 nextActor
The successful result of the future is sent as a message to the recipient, or the failure is sent in a
Status.Failure
to the recipient.
-
-