Struct WebSocketAdapter 

pub struct WebSocketAdapter { /* private fields */ }

WebSocket 适配器

提供高级 WebSocket 连接管理，包括：

• 自动连接和重连
• 消息流式接收
• 线程安全的发送

Implementations

impl WebSocketAdapter

pub fn new(url: impl Into<String>) -> Self

创建新的 WebSocket 适配器

注意：需要调用 connect() 建立连接

pub fn with_config(url: impl Into<String>, config: WebSocketConfig) -> Self

创建带配置的 WebSocket 适配器

pub async fn state(&self) -> ConnectionState

获取连接状态

pub fn abort_flag(&self) -> Arc<AtomicBool>

获取中断标志

pub fn abort(&self)

请求中断

pub async fn connect( &self, ) -> Result<WebSocketStream<MaybeTlsStream<TcpStream>>>

建立 WebSocket 连接

返回消息接收流

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

发送消息

pub async fn create_stream(&self) -> Result<WebSocketMessageStream>

创建消息流

连接 WebSocket 并返回消息接收流

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

关闭连接