Struct WsChannel 

pub struct WsChannel {
    pub write: Mutex<WsSink>,
    pub pending: Mutex<HashMap<String, Sender<ToolExecuteResponse>>>,
    pub next_id: AtomicU64,
}

Shared write half of the WebSocket, plus pending callback channels. write is type-erased via WsSink so the dispatcher can run against any transport-specific WebSocketStream (TCP or UDS today; axum-bridged in future) without templatizing every consumer.

Fields

write: Mutex<WsSink>

pending: Mutex<HashMap<String, Sender<ToolExecuteResponse>>>

Pending tool execution callbacks: request_id → oneshot sender

next_id: AtomicU64

Implementations

impl WsChannel

pub fn next_request_id(&self) -> String