PipeToSupport

public interface PipeToSupport

Nested Class Summary

Nested Classes

Modifier and Type

Interface

Description

static final class

PipeToSupport.PipeableCompletionStage<T>

static final 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)

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

<T> PipeToSupport.PipeableCompletionStage<T>

pipeCompletionStage(CompletionStage<T> future, scala.concurrent.ExecutionContext executionContext)

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

Method Details
- 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 org.apache.pekko.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 pekko.actor.Status.Failure to the recipient.
- pipeCompletionStage
  
  <T> PipeToSupport.PipeableCompletionStage<T> pipeCompletionStage(CompletionStage<T> future, scala.concurrent.ExecutionContext executionContext)
  Import this implicit conversion to gain the pipeTo method on Future:
  
  import org.apache.pekko.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 pekko.actor.Status.Failure to the recipient.