Struct WsClient

pub struct WsClient { /* private fields */ }

WebSocket JSON-RPC client

Implementations

impl WsClient

pub async fn new(url: impl Into<String>) -> Result<Self, WsClientError>

Creates a new WebSocket JSON-RPC client.

pub fn builder() -> WsClientBuilder

Creates a WsClientBuilder to configure a WsClient.

This is the same as WsClientBuilder::new().

Trait Implementations

impl BatchTransport for WsClient

fn request_batch<'life0, 'async_trait, I, M>( &'life0 self, batch: I, ) -> Pin<Box<dyn Future<Output = Result<Vec<Output>, <Self as Transport>::Error>> + Send + 'async_trait>>

where I: IntoIterator<Item = (M, Option<Params>)> + Send + 'async_trait, I::IntoIter: Send, M: Into<String> + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Send a batch of RPC calls with the given method and parameters.

impl Clone for WsClient

fn clone(&self) -> WsClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl PubsubTransport for WsClient

type NotificationStream = WsSubscription<SubscriptionNotification>

The subscription stream.

fn subscribe<'life0, 'async_trait, M>( &'life0 self, subscribe_method: M, params: Option<Params>, ) -> Pin<Box<dyn Future<Output = Result<(Id, Self::NotificationStream), <Self as Transport>::Error>> + Send + 'async_trait>>

where M: Into<String> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Add a subscription to this transport.

fn unsubscribe<'life0, 'async_trait, M>( &'life0 self, unsubscribe_method: M, subscription_id: Id, ) -> Pin<Box<dyn Future<Output = Result<bool, <Self as Transport>::Error>> + Send + 'async_trait>>

where M: Into<String> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Send an unsubscribe request to the server manually.

impl Transport for WsClient

type Error = WsClientError

The transport error type.

fn request<'life0, 'async_trait, M>( &'life0 self, method: M, params: Option<Params>, ) -> Pin<Box<dyn Future<Output = Result<Output, Self::Error>> + Send + 'async_trait>>

where M: Into<String> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Send a RPC call with the given method and parameters.