Struct sosistab::Multiplex

pub struct Multiplex { /* fields omitted */ }

A multiplex session over a sosistab session, implementing both reliable “streams” and unreliable messages.

Implementations

impl Multiplex

pub fn new(session: Session) -> Self

Creates a new multiplexed session

pub async fn send_urel(&self, msg: impl Into<Buff>) -> Result<()>

Sends an unreliable message to the other side

pub async fn recv_urel(&self) -> Result<Buff>

Receive an unreliable message

pub fn try_recv_urel(&self) -> Result<Buff>

Receive an unreliable message if there is one available.

pub async fn replace_session(&self, sess: Session)

Replaces the internal Session. This drops the previous Session, but this is not guaranteed to happen immediately.

pub async fn open_conn(&self, additional: Option<String>) -> Result<RelConn>

Open a reliable conn to the other end.

pub async fn accept_conn(&self) -> Result<RelConn>

Accept a reliable conn from the other end.