Struct Channel 

pub struct Channel {
    pub id: ChannelId,
    pub name: String,
    pub direction: Direction,
    pub subscribers: BTreeSet<u64>,
    pub sent: u64,
    pub received: u64,
    /* private fields */
}

A named channel.

Fields

id: ChannelId

name: String

direction: Direction

subscribers: BTreeSet<u64>

sent: u64

Total messages sent (including those already received).

received: u64

Total messages received.

Implementations

impl Channel

pub fn new(id: ChannelId, name: impl Into<String>, direction: Direction) -> Self

pub fn can_send(&self) -> bool

Whether the channel accepts sends.

pub fn can_receive(&self) -> bool

Whether the channel has messages for a receiver.

pub fn send( &mut self, from: LaneId, payload: Value, caps: Vec<CapId>, ) -> Result<Message>

Queue a message.

pub fn recv(&mut self) -> Result<Option<Message>>

Take the oldest message.

pub fn peek(&self) -> Option<&Message>

Peek at the oldest message without consuming it.

pub fn len(&self) -> usize

Number of queued messages.

pub fn is_empty(&self) -> bool

pub fn close(&mut self)

Close the channel: further sends and receives fail.

pub fn is_closed(&self) -> bool

Trait Implementations

impl Clone for Channel

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Channel

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

Formats the value using the given formatter.