Struct RpcOutbound 

pub struct RpcOutbound { /* private fields */ }

Writer + outbound-call tracker shared between server loops and per-session bridges (e.g. AcpChannel, RpcDispatcher).

All writes go through writer_tx so concurrent notifications and outbound requests cannot interleave bytes. Outbound requests get string ids (zc-out-<n>) disjoint from any client-issued id space.

Implementations

impl RpcOutbound

pub fn new(writer_tx: Sender<String>) -> Self

pub async fn send_raw(&self, json: String) -> bool

Send a raw pre-serialized JSON line. Returns true on success.

pub async fn closed(&self)

Resolve when the writer end is closed (peer dropped). Useful for long-lived forwarders that need to exit on disconnect even when there is no payload to send.

pub async fn notify(&self, method: &'static str, params: Value)

Send a JSON-RPC notification (no id, no response expected).

pub async fn request( &self, method: &str, params: Value, ) -> Result<Value, JsonRpcError>

Send a JSON-RPC request and await the response.

pub fn dispatch_response( &self, id_str: &str, result: Option<Value>, error: Option<JsonRpcError>, )

Route an inbound JSON-RPC response to its pending caller.

pub fn pending_count(&self) -> usize

Number of in-flight outbound requests awaiting responses.

Trait Implementations

impl Debug for RpcOutbound

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

Formats the value using the given formatter.