Struct meio::Distributor

pub struct Distributor<T> { /* fields omitted */ }

The set of multiple recipients that sends actions in parallel.

Implementations

impl<T> Distributor<T>

pub fn new() -> Self

Creates a new set of recipients.

impl<T> Distributor<T> where
    T: Action + Clone, 

pub fn insert(&mut self, recipient: Box<dyn ActionRecipient<T>>)

Adds a Recipient.

pub fn remove(&mut self, id: &Id) -> Option<Box<dyn ActionRecipient<T>>>

Remove the recipient by Id.

pub async fn act_all(&mut self, action: T) -> Result<(), Error>

Sends action to all in parallel.

pub fn len(&self) -> usize

Size of the set of recipients.

pub fn is_empty(&self) -> bool

Is this set empty?

Trait Implementations

impl<T: Debug> Debug for Distributor<T>

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

Formats the value using the given formatter.

impl<T> Default for Distributor<T>

fn default() -> Self

Returns the “default value” for a type.