Struct rpc_it::rpc::Transceiver

pub struct Transceiver(_, _);

Bidirectional RPC handle. It can serve as both client and server.

Implementations

impl Transceiver

pub fn into_sender(self) -> Sender

pub fn clone_sender(&self) -> Sender

pub fn blocking_recv(&self) -> Result<RecvMsg, RecvError>

pub async fn recv(&self) -> Result<RecvMsg, RecvError>

pub fn try_recv(&self) -> Result<RecvMsg, TryRecvError>

Methods from Deref<Target = 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 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 Transceiver

fn clone(&self) -> Transceiver

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Transceiver

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

Formats the value using the given formatter.

impl Deref for Transceiver

type Target = Sender

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl From<Transceiver> for Sender

fn from(value: Transceiver) -> Self

Converts to this type from the input type.