Struct rpc_it::rpc::Handle

pub struct Handle { /* private fields */ }

Handle to control RPC driver instance.

Implementations

impl Handle

pub fn downgrade(this: &Self) -> WeakHandle

pub fn is_closed(&self) -> bool

Check if this RPC channel was closed.

pub fn try_recv_inbound(&self) -> Result<Inbound, TryRecvError>

Try to receive single inbound from the remote end.

pub async fn recv_inbound(&self) -> Option<Inbound>

Receive single inbound from the remote end asynchronously.

Will return None if the channel is closed.

pub async fn blocking_recv_inbound(&self) -> Option<Inbound>

Receive single inbound from the remote end synchronously.

Will block until an inbound is available, or the channel is closed.

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

Flush all queued write requests. This is simply a function that forwards flush requests to the internal transport layer.

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

Shutdown underlying write stream.

pub fn pending_requests(&self) -> usize

Number of pending requests.

pub async fn request<'a, T: AsRef<[u8]> + 'a + ?Sized>( &self, route: &str, payload: impl IntoIterator<Item = &'a T> ) -> Result<ReplyWait>

Send a request to the remote end, and returns awaitable reply.

pub async fn notify<'a, T: AsRef<[u8]> + 'a + ?Sized>( &self, route: &str, payload: impl IntoIterator<Item = &'a T> ) -> Result<usize>

Send a notify to the remote end. This will return after writing all payload to underlying transport.

pub async fn request_n_bytes( &self, route: &str, payload: &mut impl Iterator<Item = &[u8]> ) -> Result<(usize, ReplyWait)>

Send a request to the remote end, and returns awaitable reply.

You can emulate timeout behavior by dropping returned future.

This version returns the number of bytes written.

Trait Implementations

impl Clone for Handle

fn clone(&self) -> Handle

Returns a copy of the value.

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

Performs copy-assignment from source.