Struct SharedWsClient 

pub struct SharedWsClient { /* private fields */ }

Shared tokio-tungstenite-backed WebSocket port implementation.

入站读任务有两条路径（按是否注入 inbound）：

• push（native/FFI engine_loop）：注入 (id, tick_tx) → 读任务把数据帧作 Tick::Inbound 直接喂泵，连接关闭/出错作 Tick::Disconnected。生产 engine_loop 从不调 recv()， 入站全靠此通道（A2，HX 入站不变量）。读任务独立持 stream 半边，不碰 send 锁。
• pull（兼容 / 单测）：无 inbound → 读任务塞内部 frame_rx，由平台生命周期 API 拉取。

Implementations

impl SharedWsClient

pub fn new(config: HostNetworkConfig) -> Result<Self, PortError>

pub fn with_registry( config: HostNetworkConfig, headers: HostHeaderRegistry, ) -> Result<Self, PortError>

pub fn headers(&self) -> HostHeaderRegistry

pub fn with_inbound_tick(self, id: TransportId, tick_tx: Sender<Tick>) -> Self

注入入站推送通道（native/FFI engine_loop 路径，A2）。

设置后，connect 的读任务把数据帧作 Tick::Inbound 直发 tick_tx、 连接关闭/出错作 Tick::Disconnected(id)，而非塞内部 frame_rx。

pub fn with_stamped_inbound_tick( self, id: TransportId, tick_tx: TickIngressSender, ) -> Self

pub fn with_metric_sink(self, metrics: Arc<dyn AsyncMetricSink>) -> Self

impl SharedWsClient

pub async fn connect(&mut self) -> Result<WsConnectionActivation, PortError>

完成物理握手，但保持 reader 暂停。

返回的 activation 必须在 sender 已进入平台路由表后消费；这样业务处理 Tick::Connected 时，Effect::Send 一定能命中当前连接。

pub async fn recv(&self) -> Result<Option<Bytes>, PortError>

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

Trait Implementations

impl FrameSender for SharedWsClient

fn send<'life0, 'async_trait>( &'life0 self, frame: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), PortError>> + Send + 'async_trait>>

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

Send one frame; fragmentation, masking and the physical socket belong to the implementing platform adapter.