Struct rpc_it::rpc::Sender

pub struct Sender(_);

Send-only handle. This holds strong reference to the connection.

Implementations

impl Sender

pub async fn call<R: DeserializeOwned>( &self, method: &str, params: &impl Serialize ) -> Result<R, CallError>

A shortcut for request, flush, and receive response.

pub async fn call_with_err<R: DeserializeOwned, E: DeserializeOwned>( &self, method: &str, params: &impl Serialize ) -> Result<R, TypedCallError<E>>

A shortcut for strictly typed request

pub async fn request<T: Serialize>( &self, method: &str, params: &T ) -> Result<ResponseFuture<'_>, SendError>

Send request, and create response future which will be resolved when the response is received.

pub async fn notify<T: Serialize>( &self, method: &str, params: &T ) -> Result<(), SendError>

Send notification message.

pub fn request_deferred<T: Serialize>( &self, method: &str, params: &T ) -> Result<ResponseFuture<'_>, SendError>

Sends a request and returns a future that will be resolved when the response is received.

This method is non-blocking, as the message writing will be deferred to the background

pub fn notify_deferred<T: Serialize>( &self, method: &str, params: &T ) -> Result<(), SendError>

Send deferred notification. This method is non-blocking, as the message writing will be deferred to the background driver worker.

pub fn is_disconnected(&self) -> bool

Check if the connection is disconnected.

pub fn close(self) -> bool

Closes the connection. If it’s already closed, it’ll return false.

Caution

If multiple threads calls this method at the same time, more than one thread may return true, as the close operation is lazy.

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

Flush underlying write stream.

pub fn is_request_enabled(&self) -> bool

Is sending request enabled?

pub fn get_feature_flags(&self) -> Feature

Get feature flags

Trait Implementations

impl Clone for Sender

fn clone(&self) -> Sender

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Sender

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

Formats the value using the given formatter.

impl From<Transceiver> for Sender

fn from(value: Transceiver) -> Self

Converts to this type from the input type.