Struct Channel 

pub struct Channel {
    pub subscribers: Vec<TaskId>,
    /* private fields */
}

spc_006-04: many-to-one / one-to-many fan-in. Unlike Mailbox, a published message is never removed from the shared buffer — each subscriber reads independently via its own cursor into that buffer (the doc’s “共享 buffer + per-consumer 已读游标” design; the cursors field is not shown in spc_006 §3’s abbreviated struct sketch but is mechanically required to realize that description — without it a second consumer draining after a first would see nothing).

Fields

subscribers: Vec<TaskId>

Implementations

impl Channel

pub fn new(subscribers: Vec<TaskId>) -> Self

pub fn publish(&mut self, msg: MailboxMessage)

pub fn publish_at( &mut self, msg: MailboxMessage, now: LogicalTime, ) -> IpcEnqueueOutcome

pub fn drain_for(&mut self, consumer: TaskId) -> Vec<MailboxMessage>

Every message published since consumer’s last drain_for, oldest first; advances that consumer’s cursor to the current end of the buffer. Independent of every other consumer’s cursor — draining does not consume the buffer.

pub fn drain_for_at( &mut self, consumer: TaskId, now: LogicalTime, ) -> Vec<MailboxMessage>

Trait Implementations

impl Clone for Channel

fn clone(&self) -> Channel

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.

impl Default for Channel

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Channel

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Channel

impl PartialEq for Channel

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for Channel

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Channel