Struct DynActorRef 

pub struct DynActorRef { /* private fields */ }

A kind of actor reference that only allows network messages to be sent

For local-only dynamically typed actors, consider using type Message = Box<Any>; together with ActorRef<Box<Any>> instead.

Implementations

impl DynActorRef

pub fn enqueue(&self, msg: NetMessage)

Enqueue a preconstructed NetMessage directly into the dynamic mailbox.

pub fn can_upgrade_component(&self) -> bool

Attempts to upgrade the contained component, returning true if possible.

This a somewhat weaker equivalent to an is_alive function, in that it doesn’t check the lifecycle status of the target component.

pub fn tell<I>(&self, v: I)

where I: Into<NetMessage>,

Send a network message to the target actor

Trait Implementations

impl Clone for DynActorRef

fn clone(&self) -> DynActorRef

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DynActorRef

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Display for DynActorRef

fn fmt(&self, fmt: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl PartialEq for DynActorRef

fn eq(&self, other: &DynActorRef) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl RoutingPolicy<DynActorRef, NetMessage> for BroadcastRouting

fn route( &self, members: &[&DynActorRef], msg: NetMessage, logger: &Logger<Arc<Fuse<Async>>>, )

Route the msg to the appropriate members

fn boxed_clone( &self, ) -> Box<dyn RoutingPolicy<DynActorRef, NetMessage> + Send + Sync>

Create a boxed copy of this policy

fn broadcast( &self, ) -> Option<&(dyn RoutingPolicy<DynActorRef, NetMessage> + Send + Sync)>

Provide the broadcast part of this policy, if any

fn select( &self, ) -> Option<&(dyn RoutingPolicy<DynActorRef, NetMessage> + Send + Sync)>

Provide the select part of this policy, if any

impl<H> RoutingPolicy<DynActorRef, NetMessage> for FieldHashBucketRouting<NetMessage, ActorPath, H>

where H: BuildHasher + Clone + Send + Sync + 'static,

fn route( &self, members: &[&DynActorRef], msg: NetMessage, logger: &Logger<Arc<Fuse<Async>>>, )

Route the msg to the appropriate members

fn boxed_clone( &self, ) -> Box<dyn RoutingPolicy<DynActorRef, NetMessage> + Send + Sync>

Create a boxed copy of this policy

fn broadcast( &self, ) -> Option<&(dyn RoutingPolicy<DynActorRef, NetMessage> + Send + Sync)>

Provide the broadcast part of this policy, if any

fn select( &self, ) -> Option<&(dyn RoutingPolicy<DynActorRef, NetMessage> + Send + Sync)>

Provide the select part of this policy, if any

impl RoutingPolicy<DynActorRef, NetMessage> for RoundRobinRouting

fn route( &self, members: &[&DynActorRef], msg: NetMessage, logger: &Logger<Arc<Fuse<Async>>>, )

Route the msg to the appropriate members

fn boxed_clone( &self, ) -> Box<dyn RoutingPolicy<DynActorRef, NetMessage> + Send + Sync>

Create a boxed copy of this policy

fn broadcast( &self, ) -> Option<&(dyn RoutingPolicy<DynActorRef, NetMessage> + Send + Sync)>

Provide the broadcast part of this policy, if any

fn select( &self, ) -> Option<&(dyn RoutingPolicy<DynActorRef, NetMessage> + Send + Sync)>

Provide the select part of this policy, if any