Struct WebSocketClient 

pub struct WebSocketClient { /* private fields */ }

WebSocket 客户端

只处理协议层，其他功能委托给 ClientCore

Implementations

impl WebSocketClient

pub fn new(config: ClientConfig) -> Self

创建新的 WebSocket 客户端

pub async fn connect_with_config(config: ClientConfig) -> Result<Self>

创建并连接

pub fn with_core(config: ClientConfig, core: ClientCore) -> Self

使用 ClientCore 创建（用于 HybridClient）

pub async fn establish_network_connection( &mut self, ) -> Result<Arc<Mutex<Box<dyn Connection>>>>

仅建立网络连接（不发送 CONNECT 消息）

用于协议竞速：先建立网络连接，选择最快协议，然后再发送 CONNECT

pub fn core(&self) -> &ClientCore

获取 ClientCore（用于外部访问）

pub async fn send_frame_and_wait( &mut self, frame: &Frame, timeout_duration: Duration, ) -> Result<Frame>

发送消息并等待服务端响应（按 Frame.message_id 匹配）

Trait Implementations

impl Client for WebSocketClient

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

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

fn set_disconnect_requested(&mut self, value: bool)

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

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

fn send_frame<'life0, 'life1, 'async_trait>( &'life0 mut self, frame: &'life1 Frame, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn is_connected(&self) -> bool

fn add_observer(&mut self, observer: ArcObserver)

fn remove_observer(&mut self, observer: ArcObserver)

fn connection_id(&self) -> Option<String>