Struct AsyncSessionEndpoint 

pub struct AsyncSessionEndpoint {
    pub remaining: SType,
    /* private fields */
}

An asynchronous session endpoint that buffers outgoing messages.

Unlike SessionEndpoint, sends do not block: they enqueue into a local outbox. The peer drains the outbox into its inbox when it is ready to receive, modelling asynchronous / buffered channels.

Fields

remaining: SType

The remaining (un-consumed) session type.

Implementations

impl AsyncSessionEndpoint

pub fn new(stype: SType) -> Self

Create a new async endpoint with the given session type.

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

Asynchronously send a message (enqueue without blocking).

pub fn flush_to(&mut self, peer: &mut AsyncSessionEndpoint) -> usize

Deliver all outgoing messages into the peer’s inbox. Returns the number of messages flushed.

pub fn async_recv(&mut self) -> Result<Message, String>

Receive a message from the inbox (must have been delivered by the peer).

pub fn outbox_len(&self) -> usize

Number of messages waiting in the outbox (not yet delivered).

pub fn inbox_len(&self) -> usize

Number of messages waiting in the inbox (delivered but not yet consumed).