Struct Connection 

pub struct Connection { /* private fields */ }

Represents a WebSocket connection

Implementations

impl Connection

pub fn new(remote_addr: SocketAddr, local_addr: SocketAddr) -> Self

Create a new connection

pub fn with_stream( remote_addr: SocketAddr, local_addr: SocketAddr, stream: Box<dyn TransportStream>, ) -> Self

Create a new connection with a transport stream

pub fn with_timeout( remote_addr: SocketAddr, local_addr: SocketAddr, stream: Box<dyn TransportStream>, idle_timeout: Option<Duration>, ) -> Self

Create a new connection with timeout settings

pub fn set_stream(&mut self, stream: Box<dyn TransportStream>)

Set the transport stream

pub fn remote_addr(&self) -> SocketAddr

Get the remote address

pub fn local_addr(&self) -> SocketAddr

Get the local address

pub fn state(&self) -> ConnectionState

Get the connection state

pub fn metadata(&self) -> &ConnectionMetadata

Get the connection metadata

pub fn is_timed_out(&self) -> bool

Check if the connection has timed out

pub fn time_until_timeout(&self) -> Option<Duration>

Get the time until the connection times out

pub fn set_idle_timeout(&mut self, timeout: Option<Duration>)

Set the idle timeout

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

Send a message

pub async fn send_text(&mut self, text: impl AsRef<str>) -> Result<()>

Send a text message

pub async fn send_binary(&mut self, data: impl Into<Bytes>) -> Result<()>

Send a binary message

pub async fn ping(&mut self, data: Option<&[u8]>) -> Result<()>

Send a ping message

pub async fn pong(&mut self, data: Option<&[u8]>) -> Result<()>

Send a pong message

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

Send a pong message (convenience method)

pub async fn next(&mut self) -> Result<Option<Message>>

Receive the next message

pub async fn close( &mut self, code: Option<u16>, reason: Option<&str>, ) -> Result<()>

Close the connection

pub fn is_connected(&self) -> bool

Check if the connection is established

pub fn is_closed(&self) -> bool

Check if the connection is closed

pub fn age(&self) -> Duration

Get the connection age

pub fn idle_time(&self) -> Duration

Get the time since last activity

Trait Implementations

impl Debug for Connection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.