pub struct RpcClientInner { /* private fields */ }Expand description
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§
Source§impl RpcClientInner
impl RpcClientInner
Sourcepub async fn get_raw_subscription(&self, id: B256) -> RawSubscription
Available on crate feature pubsub only.
pub async fn get_raw_subscription(&self, id: B256) -> RawSubscription
pubsub only.Get a RawSubscription for the given subscription ID.
§Panics
Panics if the transport does not support pubsub.
Sourcepub async fn get_subscription<T: DeserializeOwned>(
&self,
id: B256,
) -> Subscription<T>
Available on crate feature pubsub only.
pub async fn get_subscription<T: DeserializeOwned>( &self, id: B256, ) -> Subscription<T>
pubsub only.Get a Subscription for the given subscription ID.
§Panics
Panics if the transport does not support pubsub.
Source§impl RpcClientInner
impl RpcClientInner
Sourcepub fn new(t: impl IntoBoxTransport, is_local: bool) -> Self
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.
Sourcepub fn poll_interval(&self) -> Duration
pub fn poll_interval(&self) -> Duration
Returns the default poll interval (milliseconds) for the client.
Sourcepub fn set_poll_interval(&self, poll_interval: Duration)
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.
Sourcepub const fn transport(&self) -> &BoxTransport
pub const fn transport(&self) -> &BoxTransport
Returns a reference to the underlying transport.
Sourcepub const fn transport_mut(&mut self) -> &mut BoxTransport
pub const fn transport_mut(&mut self) -> &mut BoxTransport
Returns a mutable reference to the underlying transport.
Sourcepub fn into_transport(self) -> BoxTransport
pub fn into_transport(self) -> BoxTransport
Consumes the client and returns the underlying transport.
Sourcepub fn pubsub_frontend(&self) -> Option<&PubSubFrontend>
Available on crate feature pubsub only.
pub fn pubsub_frontend(&self) -> Option<&PubSubFrontend>
pubsub only.Returns a reference to the pubsub frontend if the transport supports it.
Sourcepub fn expect_pubsub_frontend(&self) -> &PubSubFrontend
Available on crate feature pubsub only.
pub fn expect_pubsub_frontend(&self) -> &PubSubFrontend
pubsub only.Returns a reference to the pubsub frontend if the transport supports it.
§Panics
Panics if the transport does not support pubsub.
Sourcepub fn make_request<Params: RpcSend>(
&self,
method: impl Into<Cow<'static, str>>,
params: Params,
) -> Request<Params>
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.
Sourcepub const fn is_local(&self) -> bool
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.
Sourcepub fn request<Params: RpcSend, Resp: RpcRecv>(
&self,
method: impl Into<Cow<'static, str>>,
params: Params,
) -> RpcCall<Params, Resp> ⓘ
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.
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for RpcClientInner
impl !RefUnwindSafe for RpcClientInner
impl Send for RpcClientInner
impl Sync for RpcClientInner
impl Unpin for RpcClientInner
impl !UnwindSafe for RpcClientInner
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> WithSubscriber for T
impl<T> WithSubscriber for T
Source§fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
Source§fn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
impl<T> ErasedDestructor for Twhere
T: 'static,
Layout§
Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.
Size: 56 bytes