Struct Client

pub struct Client<L = RpcLogger<RpcService>> { /* private fields */ }

Available on crate features async-client and async-wasm-client and client only.

Generic asynchronous client.

Implementations

impl Client<Identity>

pub fn builder() -> ClientBuilder

Create a builder for the client.

impl<L> Client<L>

pub fn is_connected(&self) -> bool

Checks if the client is connected to the target.

pub async fn on_disconnect(&self) -> Error

Completes when the client is disconnected or the client’s background task encountered an error. If the client is already disconnected, the future produced by this method will complete immediately.

Cancel safety

This method is cancel safe.

pub fn request_timeout(&self) -> Duration

Returns configured request timeout.

Trait Implementations

impl<L> ClientT for Client<L>

where L: RpcServiceT<MethodResponse = Result<MiddlewareMethodResponse, Error>, BatchResponse = Result<MiddlewareBatchResponse, Error>, NotificationResponse = Result<MiddlewareNotifResponse, Error>> + Send + Sync,

fn notification<Params>( &self, method: &str, params: Params, ) -> impl Future<Output = Result<(), Error>> + Send

where Params: ToRpcParams + Send,

Send a notification request

fn request<R, Params>( &self, method: &str, params: Params, ) -> impl Future<Output = Result<R, Error>> + Send

where R: DeserializeOwned, Params: ToRpcParams + Send,

Send a method call request.

fn batch_request<'a, R>( &self, batch: BatchRequestBuilder<'a>, ) -> impl Future<Output = Result<BatchResponse<'a, R>, Error>> + Send

where R: DeserializeOwned + 'a,

Send a batch request.

impl<L: Debug> Debug for Client<L>

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

Formats the value using the given formatter.

impl<L> Drop for Client<L>

fn drop(&mut self)

Executes the destructor for this type.

impl<L> SubscriptionClientT for Client<L>

where L: RpcServiceT<MethodResponse = Result<MiddlewareMethodResponse, Error>, BatchResponse = Result<MiddlewareBatchResponse, Error>, NotificationResponse = Result<MiddlewareNotifResponse, Error>> + Send + Sync,

fn subscribe<'a, Notif, Params>( &self, subscribe_method: &'a str, params: Params, unsubscribe_method: &'a str, ) -> impl Future<Output = Result<Subscription<Notif>, Error>> + Send

where Params: ToRpcParams + Send, Notif: DeserializeOwned,

Send a subscription request to the server.

The subscribe_method and params are used to ask for the subscription towards the server. The unsubscribe_method is used to close the subscription.

fn subscribe_to_method<N>( &self, method: &str, ) -> impl Future<Output = Result<Subscription<N>, Error>> + Send

where N: DeserializeOwned,

Subscribe to a specific method.