Package akka.pattern

Interface PipeToSupport

public interface PipeToSupport

Import this implicit conversion to gain the pipeTo method on Future:

 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.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	PipeToSupport.PipeableCompletionStage<T>
static class	PipeToSupport.PipeableFuture<T>

Method Summary

Modifier and Type	Method	Description
<T> PipeToSupport.PipeableFuture<T>	pipe(scala.concurrent.Future<T> future, scala.concurrent.ExecutionContext executionContext)
<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:

Method Detail

pipe

<T> PipeToSupport.PipeableFuture<T> pipe(scala.concurrent.Future<T> future,
                                         scala.concurrent.ExecutionContext executionContext)

pipeCompletionStage

<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:

 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.

Parameters:

future - (undocumented)

executionContext - (undocumented)

Returns:

(undocumented)