Struct Connection 

pub struct Connection { /* private fields */ }

A bidirectional channel between two end points.

Implementations

impl Connection

pub fn is_dead(&self) -> bool

Return true if the connection is dead.

pub fn start_batch(&self) -> Batch

Start a new batch of messages to be sent to the other side

pub async fn send(&self, batch: Batch) -> Result<()>

Send a batch of messages to the other side.

pub async fn send_one<S: Pack>(&self, t: &S) -> Result<()>

Send one message to the other side

pub async fn recv<R: Pack + 'static, F: FnMut(R) -> bool>( &self, f: F, ) -> Result<()>

Receive a batch of messages from the other side. Recv will repeatedly call the specified closure with new messages until either,

• the closure returns false
• there are no more messages

pub async fn try_recv<R: Pack + 'static, F: FnMut(R) -> bool>( &self, f: F, ) -> Result<()>

Receive all available messages, but do not wait for at least 1 message to arrive. If no messages are available return immediatly. This will only block if a concurrent receive is in progress.

pub async fn recv_one<R: Pack + 'static>(&self) -> Result<R>

Wait for one message from the other side, and return it when it is available.

pub async fn try_recv_one<R: Pack + 'static>(&self) -> Result<Option<R>>

Receive a message if one is available, otherwise return Ok(None).

pub fn user(&self) -> Option<UserInfo>

Return the user connected to this channel, if known