Struct JsonRpcClient 

pub struct JsonRpcClient { /* private fields */ }

Bidirectional JSON-RPC 2.0 client over a framed stdio transport.

Implementations

impl JsonRpcClient

pub fn new<R, W>( reader: R, writer: W, incoming_request_tx: Sender<IncomingRequest>, ) -> Arc<Self>

where R: AsyncBufRead + Send + Unpin + 'static, W: AsyncWrite + Send + Unpin + 'static,

Creates a new client, spawning background read/write loops.

• reader / writer: the stdio handles from the child process.
• incoming_request_tx: channel for forwarding plugin→host requests.
• Returns an Arc<JsonRpcClient> so it can be shared with host_dispatch.

pub fn close_transport(&self)

关闭传输：中止写循环，释放子进程 stdin 句柄（EOF 是 SDK 进程的退出信号）。 由 shutdown 调用，此后不再发送任何消息。

pub async fn call<P: Serialize, R: DeserializeOwned>( &self, method: &str, params: P, timeout: Duration, ) -> Result<R, ProtocolError>

Send a request and wait for the response.

pub async fn notify<P: Serialize>( &self, method: &str, params: P, ) -> Result<(), ProtocolError>

Send a notification (fire-and-forget, no response expected).

pub async fn respond_ok( &self, id: u64, result: Value, ) -> Result<(), ProtocolError>

Send a success response to a previously received request.

pub async fn respond_err( &self, id: u64, error: JsonRpcError, ) -> Result<(), ProtocolError>

Send an error response to a previously received request.

Trait Implementations

impl Debug for JsonRpcClient

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

Formats the value using the given formatter.