Struct Connection 

pub struct Connection<S> { /* private fields */ }

A portable websocket connection

Where possible, this should be used as the basis for a websocket client implementation. See the arpy-reqwasm crate for an example.

Implementations

impl<S: Spawner> Connection<S>

pub fn new( spawner: S, ws_sink: impl Sink<Vec<u8>, Error = Error> + 'static, ws_stream: impl Stream<Item = Result<Vec<u8>, Error>> + 'static, ) -> Self

Constructor.

pub async fn close(self)

Trait Implementations

impl<S: Clone> Clone for Connection<S>

fn clone(&self) -> Connection<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Spawn: Spawner> ConcurrentRpcClient for Connection<Spawn>

type Call<Output: DeserializeOwned> = Call<Output>

type Error = Error

A transport error

type SubscriptionStream<Item: DeserializeOwned> = SubscriptionStream<Item>

fn begin_call<'life0, 'async_trait, F>( &'life0 self, function: F, ) -> Pin<Box<dyn Future<Output = Result<Self::Call<F::Output>, Self::Error>> + 'async_trait>>

where F: FnRemote + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Initiate a call, but don’t wait for results until awaited again.

fn subscribe<'life0, 'async_trait, S>( &'life0 self, service: S, updates: impl 'async_trait + Stream<Item = S::Update> + 'static, ) -> Pin<Box<dyn Future<Output = Result<(S::InitialReply, SubscriptionStream<S::Item>), Error>> + 'async_trait>>

where S: FnSubscription + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Subscripte to a stream of S::Item.

fn try_begin_call<'life0, 'async_trait, F, Success, Error>( &'life0 self, function: F, ) -> Pin<Box<dyn Future<Output = Result<TryCall<Success, Error, Self>, Self::Error>> + 'async_trait>>

where 'life0: 'async_trait, Self: Sized + 'async_trait, F: FnRemote<Output = Result<Success, Error>> + 'async_trait, Success: DeserializeOwned + 'async_trait, Error: DeserializeOwned + 'async_trait,

Fallible version of Self::begin_call.

impl<S: Spawner> RpcClient for Connection<S>

type Error = Error

A transport error

fn call<'life0, 'async_trait, Args>( &'life0 self, args: Args, ) -> Pin<Box<dyn Future<Output = Result<Args::Output, Self::Error>> + 'async_trait>>

where Args: FnRemote + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Make an RPC call.

fn try_call<'life0, 'async_trait, F, Success, Error>( &'life0 self, function: F, ) -> Pin<Box<dyn Future<Output = Result<Success, ErrorFrom<Self::Error, Error>>> + 'async_trait>>

where 'life0: 'async_trait, Self: Sized + 'async_trait, F: FnRemote<Output = Result<Success, Error>> + 'async_trait, Success: 'async_trait, Error: 'async_trait,

Make a fallible RPC call.