Enum Emit 

pub enum Emit<Payload: DataLike> {
    Immediate(Payload, usize),
    Unordered(Payload, usize),
    Ordered(Payload, usize),
    ImmediateReplacement(fn(Option<Payload>) -> bool, Payload, usize),
    UnorderedReplacement(fn(Option<Payload>) -> bool, Payload, usize),
    OrderedReplacement(fn(Option<Payload>) -> bool, Payload, usize),
}

A message sent by an agent as part of an alternative action triggered by some event.

Variants

Immediate(Payload, usize)

Send a message that will be delivered immediately, before any other message is delivered.

Unordered(Payload, usize)

Send an unordered message, which will be delivered at any order relative to the other unordered messages.

Ordered(Payload, usize)

Send an ordered message, which will be delivered after delivering all previous ordered messages from this source agent to the same target agent.

ImmediateReplacement(fn(Option<Payload>) -> bool, Payload, usize)

Send an immediate message that will replace the single in-flight message accepted by the callback, or be created as a new message is the callback accepts None.

UnorderedReplacement(fn(Option<Payload>) -> bool, Payload, usize)

Send an unordered message that will replace the single in-flight message accepted by the callback, or be created as a new message is the callback accepts None.

OrderedReplacement(fn(Option<Payload>) -> bool, Payload, usize)

Send an ordered message that will replace the single in-flight message accepted by the callback, or be created as a new message is the callback accepts None.

Trait Implementations

impl<Payload: Clone + DataLike> Clone for Emit<Payload>

fn clone(&self) -> Emit<Payload>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Payload: Debug + DataLike> Debug for Emit<Payload>

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

Formats the value using the given formatter.

impl<Payload: PartialEq + DataLike> PartialEq for Emit<Payload>

fn eq(&self, other: &Emit<Payload>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<Payload: Copy + DataLike> Copy for Emit<Payload>

impl<Payload: Eq + DataLike> Eq for Emit<Payload>

impl<Payload: DataLike> StructuralPartialEq for Emit<Payload>