Fix compilation errors and minor update to the futures.md
This commit is contained in:
parent
52864ffb28
commit
8f5ea03a6f
2 changed files with 7 additions and 5 deletions
|
|
@ -95,8 +95,8 @@ or a `ClassCastException` if not. Handling `Exception`s will be discussed furthe
|
|||
|
||||
## Use the pipe pattern
|
||||
|
||||
Another useful message-transfer pattern is "pipe", which is to send the result of `Future` to another actor, upon completion of the `Future`.
|
||||
The pipe pattern can be used by importing @java[`akka.pattern.PatternsCS.pipe`.]@scala[`akka.pattern.pipe`, and define or import an implicit instance of `ExecutionContext` in the scope.
|
||||
Another useful message-transfer pattern is "pipe", which is to send the result of @scala[`Future`]@java[`CompletableFuture`] to another actor, upon completion of the @scala[`Future`]@java[`CompletableFuture`].
|
||||
The pipe pattern can be used by importing @java[`akka.pattern.PatternsCS.pipe`.]@scala[`akka.pattern.pipe`, and define or import an implicit instance of `ExecutionContext` in the scope.]
|
||||
|
||||
Scala
|
||||
: @@snip [FutureDocSpec.scala]($code$/scala/docs/future/FutureDocSpec.scala) { #pipe-to-usage }
|
||||
|
|
|
|||
|
|
@ -38,11 +38,13 @@ object FutureDocSpec {
|
|||
//#pipe-to-usage
|
||||
class ActorUsingPipeTo(target: ActorRef) extends Actor {
|
||||
// akka.pattern.pipe needs to be imported
|
||||
import akka.pattern.{ask, pipe}
|
||||
import akka.pattern.{ ask, pipe }
|
||||
// implicit ExecutionContext should be in scope
|
||||
implicit val ec: ExecutionContext = context.dispatcher
|
||||
implicit val timeout: Timeout = 5.seconds
|
||||
|
||||
def receive = {
|
||||
case _ ⇒
|
||||
val future = target ? "some message"
|
||||
future pipeTo sender() // use the pipe pattern
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue