Struct WebSocketTransport 

pub struct WebSocketTransport { /* private fields */ }

Implementations

impl WebSocketTransport

pub fn new(stream: WebSocketStream<MaybeTlsStream<TcpStream>>) -> Self

pub fn from_tcp_stream(stream: WebSocketStream<TcpStream>) -> Self

从 WebSocketStream<TcpStream> 创建（在没有 TLS 时使用）

使用单独的 Plain 类型，避免 unsafe transmute

Trait Implementations

impl Connection for WebSocketTransport

fn add_observer(&mut self, observer: ArcObserver)

Adds an observer to the connection.

fn remove_observer(&mut self, observer: ArcObserver)

Removes an observer from the connection.

fn send<'life0, 'life1, 'async_trait>( &'life0 mut self, data: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Sends data over the connection.

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Closes the connection.

fn last_active_time(&self) -> Instant

Returns last activity time (send/receive). Used for heartbeat and idle detection.

fn update_active_time(&mut self)

Updates last activity time (also called automatically on send/receive in most impls).