Struct MessageQueue 

pub struct MessageQueue { /* private fields */ }

Message queue for each endpoint

Implementations

impl MessageQueue

pub fn new(max_size: usize) -> Self

Create a new message queue

pub fn enqueue(&mut self, msg: Message) -> Result<()>

Enqueue a message

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

Dequeue a message

pub fn add_receiver(&mut self, pid: ProcessId)

Add a waiting receiver

pub fn get_receiver(&mut self) -> Option<ProcessId>

Get a waiting receiver

pub fn add_sender(&mut self, pid: ProcessId, msg: Message)

Add a waiting sender

pub fn process_waiting_senders(&mut self) -> Vec<ProcessId>

Process waiting senders (when space becomes available)

pub fn has_messages(&self) -> bool

Check if queue has messages

pub fn has_waiting_receivers(&self) -> bool

Check if there are waiting receivers