Struct WatchManagerActor 

pub struct WatchManagerActor { /* private fields */ }

Native coerce actor wrapping WatchManager.

Implementations

impl WatchManagerActor

pub fn new() -> Self

Create a new WatchManagerActor.

Trait Implementations

impl Actor for WatchManagerActor

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 WatchManagerActor

fn default() -> Self

Returns the “default value” for a type.

impl Handler<GetWatchedCount> for WatchManagerActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, _msg: GetWatchedCount, _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<OnTerminated> for WatchManagerActor

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

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

impl Handler<RemoteUnwatch> for WatchManagerActor

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

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

impl Handler<RemoteWatch> for WatchManagerActor

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

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