Struct async_jsonrpc_client::WebSocketTransport

pub struct WebSocketTransport { /* fields omitted */ }

Implementations

impl WebSocketTransport

pub fn new<U: Into<String>>(url: U) -> Self

Create a new WebSocket transport with given url.

pub fn new_with_bearer_auth<U: Into<String>, T: Into<String>>(
    url: U,
    token: T
) -> Self

Create a new WebSocket transport with given url and bearer token.

Trait Implementations

impl BatchTransport for WebSocketTransport

#[must_use]fn execute_batch<'life0, 'async_trait, I>(
    &'life0 self,
    requests: I
) -> Pin<Box<dyn Future<Output = Result<Response>> + Send + 'async_trait>> where
    I: IntoIterator<Item = (RequestId, Call)> + Send,
    I::IntoIter: Send,
    I: 'async_trait,
    'life0: 'async_trait,
    Self: Sync + 'async_trait, 

Execute a batch of prepared RPC calls.

#[must_use]fn send_batch<'life0, 'async_trait, I, M>(
    &'life0 self,
    method_and_params: I
) -> Pin<Box<dyn Future<Output = Result<Vec<Result<Value>>>> + Send + 'async_trait>> where
    I: IntoIterator<Item = (M, Params)> + Send,
    I::IntoIter: Send,
    M: Into<String>,
    I: 'async_trait,
    M: 'async_trait,
    'life0: 'async_trait,
    Self: Sync + 'async_trait, 

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

#[must_use]fn send_batch_same<'life0, 'async_trait, I, M, T>(
    &'life0 self,
    method: M,
    batch_params: I
) -> Pin<Box<dyn Future<Output = Result<Vec<T>>> + Send + 'async_trait>> where
    I: IntoIterator<Item = Params> + Send,
    I::IntoIter: Send,
    M: Into<String> + Send,
    T: DeserializeOwned,
    I: 'async_trait,
    M: 'async_trait,
    T: 'async_trait,
    'life0: 'async_trait,
    Self: Sync + 'async_trait, 

Send a batch of RPC calls with the same method and the given parameters. Once a request result returns an error, which will be returned directly.

impl Clone for WebSocketTransport

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl PubsubTransport for WebSocketTransport

fn subscribe<T>(&self, id: SubscriptionId) -> NotificationStream<T> where
    T: DeserializeOwned, 

Add a subscription to this transport

fn unsubscribe(&self, id: SubscriptionId)

Remove a subscription from this transport

impl Transport for WebSocketTransport

fn prepare<M: Into<String>>(
    &self,
    method: M,
    params: Params
) -> (RequestId, Call)

Prepare serializable RPC call for given method with parameters.

fn execute<'life0, 'life1, 'async_trait>(
    &'life0 self,
    id: RequestId,
    request: &'life1 Request
) -> Pin<Box<dyn Future<Output = Result<Response>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Execute prepared RPC call.

#[must_use]fn send<'life0, 'async_trait, M, T>(
    &'life0 self,
    method: M,
    params: Params
) -> Pin<Box<dyn Future<Output = Result<T>> + Send + 'async_trait>> where
    M: Into<String> + Send,
    T: DeserializeOwned,
    M: 'async_trait,
    T: 'async_trait,
    'life0: 'async_trait,
    Self: Sync + 'async_trait, 

Send remote method with given parameters.