Struct ProcessGroup 

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

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

Implementations

impl<M: Message> ProcessGroup<M>

pub fn new() -> Self

Creates an empty process group.

pub fn with_strategy(strategy: Strategy) -> Self

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: Message, R: Message> ProcessGroup<Call<M, R>>

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: Message> Clone for ProcessGroup<M>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M: Message> Debug for ProcessGroup<M>

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

Formats the value using the given formatter.

impl<M: Message> Default for ProcessGroup<M>

fn default() -> Self

Returns the “default value” for a type.