Enum ChannelMsg 

pub enum ChannelMsg {
    Value(Value),
    Closed,
}

Message type for plain channels.

Mirrors WeaveMessage: wrapping the underlying may::mpmc queue in a typed enum lets lifecycle signals travel through the same channel as user data without any value collision. chan.close sends one Closed sentinel; receivers re-broadcast it so all blocked consumers in an MPMC fan-out wake up. See issue #499 and docs/design/CHAN_CLOSE_SEMANTICS.md.

Variants

Value(Value)

Normal value being sent through the channel.

Closed

Channel-closed sentinel — chan.close sends one of these on the first close; chan.receive re-sends it before returning failure so the next blocked receiver also wakes.

Trait Implementations

impl Clone for ChannelMsg

fn clone(&self) -> ChannelMsg

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChannelMsg

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

Formats the value using the given formatter.

impl PartialEq for ChannelMsg

fn eq(&self, other: &ChannelMsg) -> bool

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ChannelMsg