Struct elfo::prelude::ActorGroup

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

Implementations

impl ActorGroup<(), ()>

pub fn new() -> ActorGroup<(), ()>

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

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

pub fn restart_policy(self, policy: RestartPolicy) -> ActorGroup<R, C>

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

pub fn termination_policy(self, policy: TerminationPolicy) -> ActorGroup<R, C>

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

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

pub fn exec<X, O, ER>(self, exec: X) -> Schemawhere R: Router<C>, X: Fn(Context<C, <R as Router<C>>::Key, ()>) -> O + Send + Sync + 'static, O: Future<Output = ER> + Send + 'static, ER: ExecResult, C: Config,

Trait Implementations

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

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

Formats the value using the given formatter.