Struct RemoteWatcher 

pub struct RemoteWatcher { /* private fields */ }

Implementations

impl RemoteWatcher

pub fn new( endpoint_manager: EndpointManager, registry: SerializerRegistry, local_uid: u64, ) -> Arc<Self>

pub async fn watch( self: &Arc<Self>, watcher: UntypedActorRef, watchee: ActorPath, ) -> Result<(), TransportError>

Begin watching watchee. The local watcher receives SystemMsg::Terminated if the watchee’s host disassociates.

pub async fn unwatch( self: &Arc<Self>, watcher: &UntypedActorRef, watchee: &ActorPath, )

pub fn check(&self)

Driven by the periodic supervisor task. Surfaces Terminated for any actor whose host has gone unavailable.

pub fn watch_count(&self) -> usize

Trait Implementations

impl Clone for RemoteWatcher

fn clone(&self) -> RemoteWatcher

Returns a duplicate of the value.

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

Performs copy-assignment from source.