Package akka.pattern

Interface PipeToSupport


  • public interface PipeToSupport
    • Method Detail

      • pipe

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

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