Struct RpcChadClient 

pub struct RpcChadClient {
    req_send: Sender<JsonRequest>,
    rep_recv: Receiver<JsonResult>,
    task: StoppableTaskPtr,
}

Highly experimental JSON-RPC client implementation using asynchronous channels, with each new request canceling waiting for the previous one. All requests are executed without a timeout.

Fields

req_send: Sender<JsonRequest>

The channel used to send JSON-RPC request objects

rep_recv: Receiver<JsonResult>

The channel used to read the JSON-RPC response object

task: StoppableTaskPtr

The stoppable task pointer, used on RpcChadClient::stop()

Implementations

impl RpcChadClient

pub async fn new(endpoint: Url, ex: Arc<Executor<'_>>) -> Result<Self>

Instantiate a new JSON-RPC client that connects to the given endpoint. The function takes an Executor object, which is needed to start the StoppableTask which represents the client-server connection.

pub async fn stop(&self)

Stop the JSON-RPC client. This will trigger stop() on the inner StoppableTaskPtr resulting in stopping the internal reqrep loop and therefore closing the connection.

async fn reqrep_loop( use_http: bool, stream: Box<dyn PtStream>, rep_send: Sender<JsonResult>, req_recv: Receiver<JsonRequest>, ) -> Result<()>

Internal function that loops on a given stream and multiplexes the data

pub async fn request(&self, req: JsonRequest) -> Result<JsonValue>

Send a given JSON-RPC request over the instantiated client and return a possible result. If the response is an error, returns a JsonRpcError.