Struct Connection 

pub struct Connection { /* private fields */ }

Implementations

impl Connection

pub fn id(&self) -> ConnectionId

Returns connection id.

pub fn remote_addr(&self) -> SocketAddr

Returns remote peer address.

pub fn metadata(&self) -> ConnectionMetadata

Returns immutable metadata snapshot.

pub fn close_reason(&self) -> Option<ConnectionCloseReason>

Returns close reason if connection is closed.

pub async fn send_bytes( &self, payload: impl Into<Bytes>, ) -> Result<(), SendQueueError>

Sends bytes using default send options.

pub async fn send( &self, payload: impl AsRef<[u8]>, ) -> Result<(), SendQueueError>

Sends borrowed bytes, copying into an owned payload buffer.

pub async fn send_compat( &self, stream: &[u8], _immediate: bool, ) -> Result<(), SendQueueError>

Compatibility helper matching stream-like send signatures.

pub async fn recv_bytes(&mut self) -> Result<Bytes, RecvError>

Receives next payload as zero-copy Bytes.

pub async fn recv(&mut self) -> Result<Vec<u8>, RecvError>

Receives next payload as owned Vec<u8>.

pub async fn close(&self)

Gracefully closes this connection.

pub async fn is_closed(&self) -> bool

Returns whether connection is currently closed.

pub fn into_io(self) -> ConnectionIo

Converts into Tokio AsyncRead/AsyncWrite adapter.

Trait Implementations

impl Drop for Connection

fn drop(&mut self)

Executes the destructor for this type.