Struct JsonrpseeClient

pub struct JsonrpseeClient { /* private fields */ }

Implementations

impl JsonrpseeClient

pub async fn with_default_url() -> Result<Self>

Create a new client to a local Substrate node with default port.

pub async fn new(url: &str) -> Result<Self>

Create a new client with the given url string. Example url input: “ws://127.0.0.1:9944”

pub async fn new_with_port(address: &str, port: u32) -> Result<Self>

Create a new client with the given address, port and max number of reconnection attempts. Example input:

• address: “ws://127.0.0.1”
• port: 9944

pub fn new_with_client(client: Client) -> Self

Create a new client with a user-generated Jsonrpsee Client.

impl JsonrpseeClient

pub fn is_connected(&self) -> bool

Checks if the client is connected to the target.

pub async fn disconnect_reason(&self) -> JsonrpseeError

This is similar to Client::on_disconnect but it can be used to get the reason why the client was disconnected but it’s not cancel-safe.

The typical use-case is that this method will be called after Client::on_disconnect has returned in a “select loop”.

Cancel-safety

This method is not cancel-safe

pub async fn on_disconnect(&self)

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.

Trait Implementations

impl Clone for JsonrpseeClient

fn clone(&self) -> JsonrpseeClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Request for JsonrpseeClient

fn request<'life0, 'life1, 'async_trait, R>( &'life0 self, method: &'life1 str, params: RpcParams, ) -> Pin<Box<dyn Future<Output = Result<R>> + 'async_trait>>

where R: 'async_trait + DeserializeOwned, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Sends a RPC request to the substrate node and returns the answer as string.

impl Subscribe for JsonrpseeClient

type Subscription<Notification> = SubscriptionWrapper<Notification> where Notification: DeserializeOwned

fn subscribe<'life0, 'life1, 'life2, 'async_trait, Notification>( &'life0 self, sub: &'life1 str, params: RpcParams, unsub: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Self::Subscription<Notification>>> + 'async_trait>>

where Notification: 'async_trait + DeserializeOwned, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,