Struct JsonRpcClient 

pub struct JsonRpcClient<T: Transport> { /* private fields */ }

JSON-RPC 2.0 client with bidirectional communication.

Features:

• Send requests and await responses (with timeout)
• Send notifications (fire-and-forget)
• Handle incoming notifications via callback
• Handle incoming requests (server-to-client calls) via callback
• Background read loop with automatic dispatch

Implementations

impl<T: Transport + 'static> JsonRpcClient<T>

pub fn new(transport: T) -> Self

Create a new JSON-RPC client wrapping 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).

pub async fn send_response(&self, id: JsonRpcId, result: Value) -> Result<()>

Send a response to an incoming request.

pub async fn send_error_response( &self, id: JsonRpcId, error: JsonRpcError, ) -> Result<()>

Send an error response to an incoming request.