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]
class Object
trait Matchable
class Any
Show 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
override def notice(notice: M & Notice): Unit

send notice message to this address

send notice message to this address

Value parameters

notice

notice message to send

Attributes

Definition Classes

Inherited methods

final def ask[A <: M & Ask[_ <: Reply], R <: ReplyOf[A]](ask: A)(using sender: AbstractActor[_]): FutureState[R]

Attributes

Inherited from:
Address

Concrete fields

val isLB: Boolean
val underlying: Array[ActorAddress[M]]