public interface PipeToSupport
Modifier and Type | Interface and Description |
---|---|
static class |
PipeToSupport.PipeableCompletionStage<T> |
static class |
PipeToSupport.PipeableFuture<T> |
Modifier and Type | Method and Description |
---|---|
<T> PipeToSupport.PipeableFuture<T> |
pipe(scala.concurrent.Future<T> future,
scala.concurrent.ExecutionContext executionContext)
Import this implicit conversion to gain the
pipeTo method on Future : |
<T> PipeToSupport.PipeableCompletionStage<T> |
pipeCompletionStage(java.util.concurrent.CompletionStage<T> future,
scala.concurrent.ExecutionContext executionContext)
Import this implicit conversion to gain the
pipeTo method on Future : |
<T> PipeToSupport.PipeableFuture<T> pipe(scala.concurrent.Future<T> future, scala.concurrent.ExecutionContext executionContext)
pipeTo
method on 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 Status.Failure
to the recipient.
future
- (undocumented)executionContext
- (undocumented)<T> PipeToSupport.PipeableCompletionStage<T> pipeCompletionStage(java.util.concurrent.CompletionStage<T> future, scala.concurrent.ExecutionContext executionContext)
pipeTo
method on 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 Status.Failure
to the recipient.
future
- (undocumented)executionContext
- (undocumented)