Struct Connection 

pub struct Connection { /* private fields */ }

A connection to the server.

Example

#[derive(MsgId, Serialize, Deserialize, Debug)]
struct MyAdd(u32, u32);

impl FnRemote for MyAdd {
    type Output = u32;
}

async {
    let mut conn = Connection::new(&Client::new(), "http://127.0.0.1:9090/api");
    let result = MyAdd(1, 2).call(&mut conn).await.unwrap();

    println!("1 + 2 = {result}");
};

Implementations

impl Connection

pub fn new(client: &Client, url: impl Into<String>) -> Self

Constructor.

This stores Client for connection pooling. url is the base url of the server, and will have MsgId::ID appended for each RPC.

Trait Implementations

impl Clone for Connection

fn clone(&self) -> Connection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl RpcClient for Connection

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.