Struct ActorSystem

pub struct ActorSystem { /* private fields */ }

Implementations

impl ActorSystem

pub fn new() -> Self

pub fn handler_tx(&self) -> UnboundedSender<ActorSystemCmd>

pub async fn register( &mut self, address: String, tx: UnboundedSender<Message>, restart_tx: UnboundedSender<()>, kill_tx: UnboundedSender<()>, life_cycle: LifeCycle, )

pub fn set_lifecycle(&mut self, address: &str, life_cycle: LifeCycle)

pub fn restart(&mut self, address_regex: String)

pub fn unregister(&mut self, address_regex: String)

pub async fn send<T>(&self, address: String, msg: T) -> Result<(), ActorError>

where T: Serialize + DeserializeOwned,

pub async fn send_broadcast<T>( &self, address_regex: String, msg: T, ) -> Vec<Result<(), ActorError>>

where T: Serialize + DeserializeOwned,

pub async fn send_and_recv<T, R>( &self, address: String, msg: T, ) -> Result<R, ActorError>

where T: Serialize + DeserializeOwned, R: Serialize + DeserializeOwned,

pub async fn run_job<T, R>( &self, address: String, subscript: bool, job: JobSpec, msg: T, ) -> Result<Option<UnboundedReceiver<Result<R, Error>>>, ActorError>

where T: Serialize + Clone, R: DeserializeOwned + Send + 'static,

Trait Implementations

impl Clone for ActorSystem

fn clone(&self) -> ActorSystem

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ActorSystem

fn default() -> Self

Returns the “default value” for a type.