Struct ProcessGroup 

pub struct ProcessGroup<M>
where
    M: Message,
{ /* private fields */ }

Available on crate feature actor only.

A group of actors that share messages using a routing Strategy.

Implementations

impl<M> ProcessGroup<M>

where M: Message,

pub fn new() -> ProcessGroup<M>

Creates an empty process group.

pub fn with_strategy(strategy: Strategy) -> ProcessGroup<M>

Creates an empty process group with a routing strategy.

pub fn join(&self, broker: Broker<M>) -> Membership<M>

Adds a broker until the returned membership is dropped.

pub fn send(&self, message: M) -> Result<(), DeliverError<M>>

Routes a message to the next available member.

pub fn len(&self) -> usize

Returns the number of registered members.

pub fn is_empty(&self) -> bool

Returns whether the group has no members.

impl<M, R> ProcessGroup<Call<M, R>>

where M: Message, R: Message,

pub async fn call(&self, message: M) -> Result<R, CallError<M>>

Routes a request and waits for the selected actor’s reply.

Trait Implementations

impl<M> Clone for ProcessGroup<M>

where M: Message,

fn clone(&self) -> ProcessGroup<M>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M> Debug for ProcessGroup<M>

where M: Message,

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

Formats the value using the given formatter.

impl<M> Default for ProcessGroup<M>

where M: Message,

fn default() -> ProcessGroup<M>

Returns the “default value” for a type.