public class PromiseRef$
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static PromiseRef$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
PromiseRef$() |
Modifier and Type | Method and Description |
---|---|
PromiseRef<java.lang.Object> |
apply(ActorSystem system,
Timeout timeout)
Constructs a new PromiseRef which will be completed with the first message sent to it.
|
PromiseRef<java.lang.Object> |
apply(Timeout timeout,
ActorSystem system)
Constructs a new PromiseRef which will be completed with the first message sent to it.
|
<T> PromiseRef<T> |
wrap(ActorRef actorRef,
scala.concurrent.Promise<T> promise)
Wraps an ActorRef and a Promise into a PromiseRef.
|
public static final PromiseRef$ MODULE$
public <T> PromiseRef<T> wrap(ActorRef actorRef, scala.concurrent.Promise<T> promise)
actorRef
- (undocumented)promise
- (undocumented)public PromiseRef<java.lang.Object> apply(ActorSystem system, Timeout timeout)
// enables transparent use of PromiseRef as ActorRef and Promise
import PromiseRef.Implicits._
val promiseRef = PromiseRef(system, 5.seconds)
promiseRef ! "message"
promiseRef.onComplete(println) // prints "message"
system
- (undocumented)timeout
- (undocumented)public PromiseRef<java.lang.Object> apply(Timeout timeout, ActorSystem system)
// enables transparent use of PromiseRef as ActorRef and Promise
import PromiseRef.Implicits._
// requires an implicit ActorSystem in scope
val promiseRef = PromiseRef(5.seconds)
promiseRef ! "message"
promiseRef.future.onComplete(println) // prints "message"
timeout
- (undocumented)system
- (undocumented)