RobinAddress
cc.otavia.core.address.RobinAddress
class RobinAddress[M <: Call](val underlying: Array[ActorAddress[M]], val isLB: Boolean) extends ProxyAddress[M]
Attributes
- Graph
-
- Supertypes
-
trait ProxyAddress[M]trait Address[M]trait EventableAddressclass Objecttrait Matchableclass AnyShow all
Members list
Value members
Concrete methods
override def ask[A <: M & Ask[_ <: Reply]](ask: A, future: MessageFuture[ReplyOf[A]])(using sender: AbstractActor[_ <: Call]): MessageFuture[ReplyOf[A]]
send ask message to this address
send ask message to this address
Type parameters
- A
-
the type of ask message
Value parameters
- ask
-
ask message to send
- future
-
reply message future for this ask message
- sender
-
who send this ask message
Attributes
- Definition Classes
override def ask[A <: M & Ask[_ <: Reply]](ask: A, f: MessageFuture[ReplyOf[A]], timeout: Long)(using sender: AbstractActor[_ <: Call]): MessageFuture[ReplyOf[A]]
send ask message to this address, and set timeout milliseconds to get the respect Reply, otherwise the MessageFuture will set scala.concurrent.TimeoutException.
send ask message to this address, and set timeout milliseconds to get the respect Reply, otherwise the MessageFuture will set scala.concurrent.TimeoutException.
Type parameters
- A
-
the type of ask message
Value parameters
- ask
-
ask message to send
- f
-
reply message future for this ask message
- sender
-
who send this ask message
- timeout
-
max time to wait for the Reply message.
Attributes
- Definition Classes
override def askUnsafe(ask: Ask[_], f: MessageFuture[_])(using sender: AbstractActor[_]): MessageFuture[_]
Attributes
- Definition Classes
In this article