Struct JsonRpcClientState 

pub struct JsonRpcClientState(/* private fields */);

The jsonrpc client without Drop support.

Implementations

impl JsonRpcClientState

pub fn new(max_send_queue_size: usize) -> Self

Create a new JsonRpcClient with provided send cache channel length.

pub async fn call<M, P, R>(&self, method: M, params: P) -> Result<R>

where M: AsRef<str>, P: Serialize, for<'a> R: Deserialize<'a>,

Invoke a jsonrpc v2.0 call and waiting for response.

pub async fn send(&self) -> Result<(usize, Vec<u8>)>

Writes a single jsonrpc packet to be sent to the peer.

pub async fn recv<V: AsRef<[u8]>>(&self, packet: V) -> Result<()>

Processes jsonrpc packet received from the peer.

pub fn close(&self)

Close the jsonrpc client.

pub fn is_closed(&self) -> bool

Returns true if this client is already closed.

Trait Implementations

impl Clone for JsonRpcClientState

fn clone(&self) -> JsonRpcClientState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.