Struct RpcClient

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

A JSON-RPC client.

RpcClient should never be instantiated directly. Instead, use ClientBuilder.

Implementations

impl RpcClient

pub const fn builder() -> ClientBuilder<Identity>

Create a new ClientBuilder.

impl RpcClient

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

Creates a new RpcClient with the given transport.

pub fn mocked(asserter: Asserter) -> Self

Create a new RpcClient with a transport that returns mocked responses from the given Asserter.

pub fn from_inner(inner: RpcClientInner) -> Self

Creates a new RpcClient with the given inner client.

pub const fn inner(&self) -> &Arc<RpcClientInner>

Get a reference to the client.

pub fn into_inner(self) -> Arc<RpcClientInner>

Convert the client into its inner type.

pub fn get_weak(&self) -> WeakClient

Get a Weak reference to the client.

pub fn get_ref(&self) -> ClientRef<'_>

Borrow the client.

pub fn with_poll_interval(self, poll_interval: Duration) -> Self

Sets the poll interval for the client in milliseconds.

Note: This will only set the poll interval for the client if it is the only reference to the inner client. If the reference is held by many, then it will not update the poll interval.

pub fn prepare_static_poller<Params, Resp>( &self, method: impl Into<Cow<'static, str>>, params: Params, ) -> PollerBuilder<Params, Resp>

where Params: RpcSend + 'static, Resp: RpcRecv + Clone,

Build a poller that polls a method with the given parameters.

See PollerBuilder for examples and more details.

pub fn boxed(self) -> Self

👎Deprecated since 0.9.0: RpcClient is now always boxed

Boxes the transport.

pub fn new_batch(&self) -> BatchRequest<'_>

Create a new BatchRequest builder.

Methods from Deref<Target = RpcClientInner>

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 fn transport(&self) -> &BoxTransport

Returns a reference to 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 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 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.

Trait Implementations

impl Clone for RpcClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RpcClient

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

Formats the value using the given formatter.

impl Deref for RpcClient

type Target = RpcClientInner

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.