Struct ArcClient

pub struct ArcClient<C> { /* private fields */ }

Wraps a client into an Arc<Mutex<_>>, so that it can be cloned.

Implementations

impl<C: Client> ArcClient<C>

pub fn new(inner: C) -> Self

Creates a new ArcClient from the inner client.

Trait Implementations

impl<C: Client + Send> Client for ArcClient<C>

type Error = <C as Client>::Error

Error type that this client returns.

fn send_request<'life0, 'life1, 'life2, 'async_trait, P, R>( &'life0 self, method: &'life1 str, params: &'life2 P, ) -> Pin<Box<dyn Future<Output = Result<R, Self::Error>> + Send + 'async_trait>>

where P: Serialize + Debug + Send + Sync + 'async_trait, R: for<'de> Deserialize<'de> + Debug + Send + Sync + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Sends a JSON-HTTP request

fn connect_stream<'life0, 'async_trait, T>( &'life0 self, id: SubscriptionId, ) -> Pin<Box<dyn Future<Output = BoxStream<'static, T>> + Send + 'async_trait>>

where T: for<'de> Deserialize<'de> + Debug + Send + Sync + 'async_trait + Unpin + 'static, Self: 'async_trait, 'life0: 'async_trait,

If the client supports streams (i.e. receiving notifications), this should return a stream for the specific subscription ID.

fn disconnect_stream<'life0, 'async_trait>( &'life0 self, id: SubscriptionId, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

If the client supports streams (i.e. receiving notifications) and there is a matching subscription ID, this should close the corresponding stream.

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Closes the client connection

impl<C> Clone for ArcClient<C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.