Struct StdioJsonRpcClient 

pub struct StdioJsonRpcClient { /* private fields */ }

JSON-RPC client for stdio transports with separate read/write paths.

This client avoids the lock contention issue by using separate mutexes for reading and writing.

Implementations

impl StdioJsonRpcClient

pub fn new(transport: StdioTransport) -> Self

Create a new stdio JSON-RPC client from a transport.

pub async fn start(&self) -> Result<()>

Start the background read loop.

pub async fn stop(&self)

Stop the client.

pub fn is_running(&self) -> bool

Check if client is running.

pub async fn set_notification_handler<F>(&self, handler: F)

where F: Fn(&str, &Value) + Send + Sync + 'static,

Set handler for incoming notifications.

pub async fn set_request_handler<F>(&self, handler: F)

where F: Fn(&str, &Value) -> RequestHandlerFuture + Send + Sync + 'static,

Set handler for incoming requests.

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

Send a request and await response.

pub async fn invoke_with_timeout( &self, method: &str, params: Option<Value>, timeout: Duration, ) -> Result<Value>

Send a request with custom timeout.

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

Send a notification (no response expected).