Struct workflow_rpc::asynchronous::client::RpcClient

pub struct RpcClient<Ops>where
    Ops: TryInto<u32> + Send + Sync + 'static,{ /* private fields */ }

Implementations

impl<Ops> RpcClient<Ops>where
    Ops: Into<u32> + Send + Sync + 'static,

pub fn new(url: &str) -> Result<RpcClient<Ops>>

pub fn init_ctl(&self) -> Receiver<Ctl>

pub async fn connect(
    &self,
    block_until_connected: bool
) -> Result<Option<Listener>>

pub async fn shutdown(&self) -> Result<()>

pub fn is_open(&self) -> bool

pub async fn call_callback_with_buffer(
    &self,
    op: Ops,
    message: Message<'_>,
    callback: RpcResponseFn
) -> Result<()>

pub async fn call_async_with_buffer(
    &self,
    op: Ops,
    message: Message<'_>
) -> Result<Vec<u8>>

pub async fn call<Req, Resp>(&self, op: Ops, req: Req) -> Result<Resp>where
    Req: BorshSerialize + Send + Sync + 'static,
    Resp: BorshDeserialize + Send + Sync + 'static,

Trait Implementations

impl<Ops: Clone> Clone for RpcClient<Ops>where
    Ops: TryInto<u32> + Send + Sync + 'static,

fn clone(&self) -> RpcClient<Ops>

Returns a copy of the value.

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

Performs copy-assignment from source.