Struct TcpJsonRpcClient 

pub struct TcpJsonRpcClient { /* private fields */ }

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

Implementations

impl TcpJsonRpcClient

pub async fn connect(addr: impl AsRef<str>) -> Result<Self>

Connect to a TCP JSON-RPC server.

pub fn new(stream: TcpStream) -> Self

Create a new TCP JSON-RPC client from a connected socket.

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).