Struct Connection 

pub struct Connection { /* private fields */ }

WebSocket connection

Implementations

impl Connection

pub fn new( ws: WebSocketStream<TcpStream>, remote_addr: SocketAddr, codec: ProtocolCodec, ) -> (Self, UnboundedReceiver<Message>)

Create a new connection

pub fn id(&self) -> ConnectionId

Get connection ID

pub fn remote_addr(&self) -> SocketAddr

Get remote address

pub async fn state(&self) -> ConnectionState

Get connection state

pub async fn set_state(&self, new_state: ConnectionState)

Set connection state

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

Send a message

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

Receive a message

pub async fn process_outgoing( &self, rx: UnboundedReceiver<Message>, ) -> Result<()>

Process outgoing messages

pub async fn ping(&self) -> Result<()>

Send a ping

pub async fn close(&self) -> Result<()>

Close the connection

pub async fn metadata(&self) -> ConnectionMetadata

Get metadata

pub async fn update_metadata<F>(&self, f: F)

where F: FnOnce(&mut ConnectionMetadata),

Update metadata

pub fn last_activity(&self) -> u64

Get last activity timestamp

pub fn is_idle(&self, timeout_secs: u64) -> bool

Check if connection is idle

pub fn stats(&self) -> ConnectionStats

Get statistics