Package org.apache.pekko.pattern

Class PromiseRef$

java.lang.Object

org.apache.pekko.pattern.PromiseRef$

public class PromiseRef$
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final PromiseRef$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
PromiseRef$()

Method Summary

Modifier and Type	Method	Description
PromiseRef<Object>	apply(ActorSystem system, Timeout timeout)	Constructs a new PromiseRef which will be completed with the first message sent to it.
PromiseRef<Object>	apply(Timeout timeout, ActorSystem system)	Constructs a new PromiseRef which will be completed with the first message sent to it.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final PromiseRef$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

PromiseRef$

public PromiseRef$()

Method Details

apply

public PromiseRef<Object> apply(ActorSystem system,
 Timeout timeout)

Constructs a new PromiseRef which will be completed with the first message sent to it.

 // 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"
 

apply

public PromiseRef<Object> apply(Timeout timeout,
 ActorSystem system)

Constructs a new PromiseRef which will be completed with the first message sent to it.

 // 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"