[−][src]Trait sealrs::actors::abstract_actor_system::AbstractActorSystem

pub trait AbstractActorSystem: ActorRefFactory {
    fn get_scheduler(&self) -> TSafe<Scheduler>;

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

    fn terminate(&mut self);

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

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

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

Required methods

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_executor(&self, name: &str) -> TSafe<dyn Executor + Send>

Returns dispatcher by name as executor

Loading content...

Implementors

impl AbstractActorSystem for LocalActorSystem[src]

fn get_scheduler(&self) -> TSafe<Scheduler>[src]

Returns actor system scheduler

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

Register new watching event from the specified actor

fn terminate(&mut self)[src]

Stops the actor system

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

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

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

Returns dispatcher by name

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

Returns dispatcher by name as executor

impl AbstractActorSystem for TestLocalActorSystem[src]

fn get_scheduler(&self) -> TSafe<Scheduler>[src]

Identical to original

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

Register new watching event from the specified actor

fn terminate(&mut self)[src]

Stops the actor system

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

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

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

Returns dispatcher by name

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

Returns dispatcher by name as executor

Loading content...