Struct InMemoryTransport 

pub struct InMemoryTransport { /* private fields */ }

InMemoryTransport — 跨线程同步 CDP 桥接 Transport 实现。

持有:

• Arc<dyn InMemoryBridge>:命令派发(servo 端)
• event_rx:事件接收 channel(InMemoryBridge 侧 push,CDP client 侧 recv)
• event_tx:event_rx 的 sender 克隆,作为构造时的“事件入口“接口
• servo_event_rx(可选):servo 7 类事件接收 channel(REQ-BAO-API-003)。 通过 InMemoryTransport::attach_servo_event_receiver 接入, recv_event 会优先消费 servo 事件(translate 为 CDP event 后返回); 无 servo 事件时 fallback 到普通 event_rx(供测试 mock 直接 push CDP event)。
• pending_cdp_events:servo 事件 translate 后可能产生多个 CDP event, 未返回的暂存在这里。

关闭语义:close() drop sender/receiver,后续命令返回 ConnectionClosed。

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

Implementations

impl InMemoryTransport

pub fn new(bridge: Arc<dyn InMemoryBridge>) -> InMemoryTransport

构造 InMemory transport,桥接到指定的 InMemoryBridge 实现。

TASK-2 内可传入 mock bridge 用于单元测试;TASK-3 内传入真实 servo bridge。

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

pub fn event_sender(&self) -> Sender<CdpEvent>

获取事件 sender 克隆 — 供 servo 端(InMemoryBridge 实现)向 CDP client 推送事件。

调用方(servo delegate)持有一份 sender,在 servo 触发事件时调用 event_sender.send(CdpEvent::new(...)) 即可被 recv_event() 收到。

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

pub fn attach_servo_event_receiver(&mut self, rx: Receiver<ServoEvent>)

接入 servo 事件 receiver(REQ-BAO-API-003)。

接入后,recv_event 会优先消费 servo 事件并经 crate::bridge::event_translator::translate 转换为 CDP event。 无 servo 事件时 fallback 到普通 event_rx(供测试直接 push CDP event)。

通常与 crate::bridge::EventSubscriber::new 配合使用:

use bao_cdp_client::bridge::{CDPRdpBridge, EventSubscriber, MockServoBackend, ServoBackend};
use bao_cdp_client::transport::{InMemoryBridge, InMemoryTransport};
use std::sync::Arc;

let backend: Arc<dyn ServoBackend> = Arc::new(MockServoBackend::new());
let bridge = CDPRdpBridge::new(backend);
let bridge_dyn: Arc<dyn InMemoryBridge> = bridge.into_in_memory_bridge();
let mut transport = InMemoryTransport::new(bridge_dyn);
let (subscriber, rx) = EventSubscriber::new();
transport.attach_servo_event_receiver(rx);
// 把 subscriber 注册到 servo delegate...
let _ = subscriber;

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

pub fn is_closed(&self) -> bool

是否已关闭。

Trait Implementations

impl Debug for InMemoryTransport

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

Formats the value using the given formatter.

impl Transport for InMemoryTransport

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)

设置默认事件接收超时。