Struct AsyncSession 

pub struct AsyncSession<S> { /* private fields */ }

Async equivalent of Session. Wrap establishment in one timeout. Cancelling a frame read or write poisons the session; it cannot resume on a byte prefix.

Implementations

impl<S: AsyncRead + AsyncWrite + Unpin> AsyncSession<S>

pub async fn connect(io: S, offer: &Hello) -> Result<Self>

Establish a client session on an advertised binary endpoint.

pub async fn accept(io: S, offer: &Hello) -> Result<Self>

Establish a server session after the caller has authenticated the peer.

pub async fn refuse(io: S, offer: &Hello, reason: Refused) -> Result<()>

Async equivalent of Session::refuse.

pub fn agreement(&self) -> Agreement

Negotiated capabilities and message bound.

pub async fn send(&mut self, message: &Control) -> Result<()>

Send one operation. Failure or cancellation must never trigger replay.

pub async fn receive(&mut self) -> Result<Control>

Receive one operation; cancellation prevents further use of this session.