Struct RpcClientInner

pub struct RpcClientInner { /* private fields */ }

A JSON-RPC client.

This struct manages a BoxTransport and a request ID counter. It is used to build RpcCall and BatchRequest objects. The client delegates transport access to the calls.

Note

IDs are allocated sequentially, starting at 0. IDs are reserved via RpcClientInner::next_id. Note that allocated IDs may not be used. There is no guarantee that a prepared RpcCall will be sent, or that a sent call will receive a response.

Implementations

impl RpcClientInner

pub fn new(t: impl IntoBoxTransport, is_local: bool) -> Self

Create a new RpcClient with the given transport.

Note: Sets the poll interval to 250ms for local transports and 7s for remote transports by default.

pub fn with_id(self, id: u64) -> Self

Sets the starting ID for the client.

pub fn poll_interval(&self) -> Duration

Returns the default poll interval (milliseconds) for the client.

pub fn set_poll_interval(&self, poll_interval: Duration)

Set the poll interval for the client in milliseconds. Default: 7s for remote and 250ms for local transports.

pub const fn transport(&self) -> &BoxTransport

Returns a reference to the underlying transport.

pub const fn transport_mut(&mut self) -> &mut BoxTransport

Returns a mutable reference to the underlying transport.

pub fn into_transport(self) -> BoxTransport

Consumes the client and returns the underlying transport.

pub fn make_request<Params: RpcSend>( &self, method: impl Into<Cow<'static, str>>, params: Params, ) -> Request<Params>

Build a JsonRpcRequest with the given method and params.

This function reserves an ID for the request, however the request is not sent.

To send a request, use RpcClientInner::request and await the returned RpcCall.

pub const fn is_local(&self) -> bool

true if the client believes the transport is local.

This can be used to optimize remote API usage, or to change program behavior on local endpoints. When the client is instantiated by parsing a URL or other external input, this value is set on a best-efforts basis and may be incorrect.

pub const fn set_local(&mut self, is_local: bool)

Set the is_local flag.

pub fn next_id(&self) -> Id

Reserve a request ID u64.

pub fn request<Params: RpcSend, Resp: RpcRecv>( &self, method: impl Into<Cow<'static, str>>, params: Params, ) -> RpcCall<Params, Resp>

Prepares an RpcCall.

This function reserves an ID for the request, however the request is not sent. To send a request, await the returned RpcCall.

Note

Serialization is done lazily. It will not be performed until the call is awaited. This means that if a serializer error occurs, it will not be caught until the call is awaited.

pub fn request_noparams<Resp: RpcRecv>( &self, method: impl Into<Cow<'static, str>>, ) -> RpcCall<NoParams, Resp>

Prepares an RpcCall with no parameters.

See request for more details.

pub fn boxed(self) -> Self

👎Deprecated since 0.9.0: RpcClientInner is now always boxed

Type erase the service in the transport, allowing it to be used in a generic context.

Trait Implementations

impl Debug for RpcClientInner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.