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 fn my_app<Conn: RpcClient>(conn: &mut Conn) -> Result<(), Conn::Error> {
    let result = MyAdd(1, 2).call(conn).await?;

    assert_eq!(3, result);

    Ok(())
}

async {
    my_app(&mut http::Connection::new("http://127.0.0.1:9090/api/http"))
        .await
        .unwrap();
};

Implementations

impl Connection

pub fn new(url: &str) -> Self

Constructor.

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.