Struct WebSocketTransport 

pub struct WebSocketTransport { /* private fields */ }

WebSocketTransport — 外部 Chrome CDP 客户端模式。

包装 bun_uws::ws_client::WebSocketClient。Transport trait 接口不变。

@trace REQ-BAO-API-002 [interface:Transport] @trace REQ-CDP-UWS-001

Implementations

impl WebSocketTransport

pub fn connect(url: &str) -> Result<WebSocketTransport, CdpError>

连接到 WebSocket CDP endpoint。

url 必须是 ws://host:port/path 形式(wss:// TLS 后续 TASK 增加)。

错误

• CdpError::HandshakeError:URL 格式错误 / 握手失败
• CdpError::IoError:TCP 连接失败

@trace REQ-BAO-API-002 [interface:Transport]

pub fn connect_on_stream( stream: TcpStream, host: &str, path: &str, ) -> Result<WebSocketTransport, CdpError>

用已建立的 TcpStream 完成 handshake 并包装。

主要用于测试(mock server 跑在本地端口)。

@trace REQ-BAO-API-002 [interface:Transport]

pub fn is_closed(&self) -> bool

是否已关闭。

pub fn current_id(&self) -> u64

当前 next id(测试断言用)。

Trait Implementations

impl Debug for WebSocketTransport

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Transport for WebSocketTransport

fn kind(&self) -> TransportKind

返回 transport 类型标识。

fn send_command( &mut self, method: &str, params: Value, session_id: Option<&str>, ) -> Result<Value, CdpError>

发送 CDP 命令,阻塞等待响应。

fn recv_event(&mut self) -> Result<Option<CdpEvent>, CdpError>

接收服务器推送事件,阻塞直到事件到达或超时。

fn close(&mut self) -> Result<(), CdpError>

优雅关闭 Transport。

fn set_command_timeout(&mut self, timeout: Duration)

设置默认命令超时。

fn set_event_timeout(&mut self, timeout: Duration)

设置默认事件接收超时。