Struct ockam_node::RpcClient

pub struct RpcClient { /* private fields */ }

Generic client for request / response communication over a route

Implementations

impl RpcClient

pub async fn new(r: Route, ctx: &Context) -> Result<Self>

Create a new RpcClient

pub fn with_timeout(self, timeout: Duration) -> Self

Specify a timeout for the RpcClient

pub fn with_flow_controls(self, flow_controls: &FlowControls) -> Self

Specify the flow controls to use for the RpcClient

pub async fn request<T, R>(&self, req: &RequestBuilder<'_, T>) -> Result<R>where T: Encode<()>, R: for<'a> Decode<'a, ()>,

Encode request header and body (if any) and send the package to the server.

pub async fn request_no_resp_body<T>( &self, req: &RequestBuilder<'_, T> ) -> Result<()>where T: Encode<()>,

Encode request header and body (if any) and send the package to the server.

Trait Implementations

impl Debug for RpcClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.