Struct rosey_actors::prelude::ActorItem

pub struct ActorItem {
    pub id: &'static str,
    // some fields omitted
}

Fields

id: &'static str

Implementations

impl ActorItem

pub fn new(
    id: &'static str,
    factory: &'static (dyn Fn() -> Actor + Send + Sync)
) -> Self

pub fn register_and_start(self, ctx: &mut Ctx)

pub fn on_error<R: Strategy<(usize, Result<(), ActorError>)> + 'static>(
    self,
    r: R
) -> Self

pub fn on_panic<R: Strategy<usize> + 'static>(self, r: R) -> Self

pub fn send(&mut self, msg: BoxedMessage)

pub async fn stop(&mut self)

pub async fn restart(&mut self)

pub fn actor_task_finished<'a>(
    &'a mut self,
    ctx: &'a Ctx,
    result: Option<Result<(), ActorError>>
) -> impl Future<Output = ()> + 'a

pub async fn stop_and_cache_messages(&mut self)

pub fn clean_up_retry_arbitrer(&mut self)

pub fn shutdown(&mut self)

pub async fn join(&mut self)

pub async fn start(&mut self, ctx: &Ctx) -> Result<(), ActorError>