Struct WebSocketConnection 

pub struct WebSocketConnection { /* private fields */ }

An active WebSocket connection.

Use next() to receive events, or convert to a Stream for async iteration.

Implementations

impl WebSocketConnection

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

Receive the next WebSocket event.

Returns None if the connection is closed.

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

Send a ping message.

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

Close the WebSocket connection gracefully.

pub fn time_since_last_ping(&self) -> Duration

Get the time since the last ping was received.

pub fn into_stream(self) -> WebSocketEventStream

Convert this connection into a Stream of events.