Struct sealrs::actors::remoting::remote_actor_system::RemoteActorSystem

pub struct RemoteActorSystem { /* fields omitted */ }

Methods

impl RemoteActorSystem

pub fn new(
    addr: SocketAddr,
    host_system: TSafe<dyn ActorRefFactory + Send>,
    messages_serializer: TSafe<dyn MessagesSerializer + Send>
) -> RemoteActorSystem

Trait Implementations

impl ActorRefFactory for RemoteActorSystem

fn actor_of(&mut self, props: Props, name: Option<&str>) -> ActorRef

fn actor_select(&mut self, path: &str) -> Vec<ActorRef>

fn stop(&mut self, aref: &mut ActorRef)

fn dead_letters(&mut self) -> ActorRef

fn watch(&mut self, watcher: &ActorRef, observed: &ActorRef)

Register watcher for receive 'watching events' from observed actor

fn unwatch(&mut self, watcher: &ActorRef, observed: &ActorRef)

Unregister watcher from receive 'watching events' from observed actor

impl AbstractActorSystem for RemoteActorSystem

fn get_scheduler(&self) -> TSafe<Scheduler>

Returns actor system scheduler

fn register_watch_event(&self, from: &ActorRef, event: WatchingEvents)

Register new watching event from the specified actor

fn terminate(&mut self)

Stops the actor system

fn add_dispatcher(
    &mut self,
    name: &str,
    dispatcher: TSafe<dyn Dispatcher + Send>
)

Adds new dispatcher to the system. For now supporter only default dispatcher replacing

fn get_dispatcher(&self, name: &str) -> TSafe<dyn Dispatcher + Send>

Returns dispatcher by name

fn get_dispatchers(
    &self
) -> TSafe<HashMap<String, TSafe<dyn Dispatcher + Send>>>

Returns dispatchers list

fn get_executor(&self, name: &str) -> TSafe<dyn Executor + Send>

Returns dispatcher by name as executor

fn get_nid(&mut self) -> String

Return actor auto name

impl Drop for RemoteActorSystem

fn drop(&mut self)

Executes the destructor for this type.