Struct fizyr_rpc::SentRequestHandle[−][src]

pub struct SentRequestHandle<Body> { /* fields omitted */ }

Expand description

A handle for a sent request.

The handle can be used to receive updates and the response from the remote peer, and to send update messages to the remote peer.

Implementations

impl<Body> SentRequestHandle<Body>

pub fn request_id(&self) -> u32

Get the request ID of the sent request.

pub fn service_id(&self) -> i32

Get the service ID of the initial request message.

pub fn write_handle(&self) -> SentRequestWriteHandle<Body>

Create a write handle for this request.

The write handle can be cloned and used even while this handle is mutably borrowed.

pub async fn recv_update(&mut self) -> Option<Message<Body>>

Receive the next update message of the request from the remote peer.

This function returns None if the final response is received instead of an update message. If that happens, the response message can be read using Self::recv_response.

pub async fn recv_response(&mut self) -> Result<Message<Body>, Error>

Receive the final response of the request from the remote peer.

This function returns an error if the received message is an update message. You can detect this situation using Error::is_unexpected_message_type(). Afterwards, the update message can be read using Self::recv_update. To ensure that there are no update messages left, keep calling Self::recv_update untill it returns Ok(None).

pub async fn send_update(
    &self,
    service_id: i32,
    body: impl Into<Body>
) -> Result<(), Error>

Send an update for the request to the remote peer.

Trait Implementations

impl<Body> Debug for SentRequestHandle<Body>

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

Formats the value using the given formatter. Read more

Auto Trait Implementations

impl<Body> !RefUnwindSafe for SentRequestHandle<Body>

impl<Body> Send for SentRequestHandle<Body> where
Body: Send,

impl<Body> Sync for SentRequestHandle<Body> where
Body: Send + Sync,

impl<Body> Unpin for SentRequestHandle<Body> where
Body: Unpin,

impl<Body> !UnwindSafe for SentRequestHandle<Body>

Blanket Implementations

impl<T> Any for T where
T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T where
T: ?Sized,

pub fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T where
T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

pub fn from(t: T) -> T

Performs the conversion.

impl<T, U> Into<U> for T where
U: From<T>,

pub fn into(self) -> U

Performs the conversion.

impl<T, U> TryFrom<U> for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.