Struct ActorGroup

pub struct ActorGroup<R, C> { /* private fields */ }

Implementations

impl ActorGroup<(), ()>

pub fn new() -> Self

impl<R, C> ActorGroup<R, C>

pub fn config<C1: Config>(self) -> ActorGroup<R, C1>

pub fn restart_policy(self, policy: RestartPolicy) -> Self

The behaviour on actor termination. RestartPolicy::on_failures is used by default.

pub fn termination_policy(self, policy: TerminationPolicy) -> Self

The behaviour on the Terminate message. TerminationPolicy::closing is used by default.

pub fn router<R1: Router<C>>(self, router: R1) -> ActorGroup<R1, C>

pub fn exec<X, O, ER>(self, exec: X) -> Schema

where R: Router<C>, X: Fn(Context<C, R::Key>) -> O + Send + Sync + 'static, O: Future<Output = ER> + Send + 'static, ER: ExecResult, C: Config,

Trait Implementations

impl<R: Debug, C: Debug> Debug for ActorGroup<R, C>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.