Struct NodeDirectoryActor 

pub struct NodeDirectoryActor { /* private fields */ }

Native coerce actor wrapping NodeDirectory.

Implementations

impl NodeDirectoryActor

pub fn new() -> Self

Create a new NodeDirectoryActor.

Trait Implementations

impl Actor for NodeDirectoryActor

fn new_context( &self, system: Option<ActorSystem>, status: ActorStatus, boxed_ref: BoxedActorRef, ) -> ActorContext

Creates a new ActorContext, allowing actor implementations to override specific parts of the ActorContext, before the actor is started.

fn started<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Called once the Actor has been started

fn stopped<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Called once the Actor has stopped

fn on_child_stopped<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, _id: &'life1 Arc<str>, _ctx: &'life2 mut ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

Called when a supervised actor has stopped

fn actor_ref(&self, ctx: &ActorContext) -> LocalActorRef<Self>

where Self: Sized,

Returns a LocalActorRef<Self> instance of the current actor, automatically casting from the ActorContext’s BoxedActorRef.

fn type_name() -> &'static str

where Self: Sized,

Returns the actor’s type name string

fn tags(&self, ctx: &ActorContext) -> ActorTags

const DEFAULT_TAGS: ActorTags = { ActorTags::None }

Default tags used when creating the actor

impl Default for NodeDirectoryActor

fn default() -> Self

Returns the “default value” for a type.

impl Handler<ConnectPeer> for NodeDirectoryActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: ConnectPeer, _ctx: &'life1 mut ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Handler<DisconnectPeer> for NodeDirectoryActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: DisconnectPeer, _ctx: &'life1 mut ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Handler<GetConnectedCount> for NodeDirectoryActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, _msg: GetConnectedCount, _ctx: &'life1 mut ActorContext, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Handler<GetPeerCount> for NodeDirectoryActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, _msg: GetPeerCount, _ctx: &'life1 mut ActorContext, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Handler<GetPeerInfo> for NodeDirectoryActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: GetPeerInfo, _ctx: &'life1 mut ActorContext, ) -> Pin<Box<dyn Future<Output = Option<PeerInfo>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Handler<IsConnected> for NodeDirectoryActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: IsConnected, _ctx: &'life1 mut ActorContext, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,