Struct fizyr_rpc::ReceivedRequestHandle[−][src]

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

Expand description

A handle for a received request.

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

Implementations

[src]

impl<Body> ReceivedRequestHandle<Body>

[src]

pub fn request_id(&self) -> u32

Get the request ID of the received request.

[src]

pub fn service_id(&self) -> i32

Get the service ID of the received request message.

[src]

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

Create a write handle for this request.

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

[src]

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

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

[src]

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.

[src]

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

Send the final response for the request to the remote peer.

[src]

pub async fn send_error_response(&self, message: &str) -> Result<(), Error> where
Body: Body,

Send the final response with an error message.

Trait Implementations

[src]

impl<Body> Debug for ReceivedRequestHandle<Body>

[src]

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

Formats the value using the given formatter. Read more

Auto Trait Implementations

impl<Body> !RefUnwindSafe for ReceivedRequestHandle<Body>

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

impl<Body> Sync for ReceivedRequestHandle<Body> where
Body: Send,

impl<Body> Unpin for ReceivedRequestHandle<Body>

impl<Body> !UnwindSafe for ReceivedRequestHandle<Body>

Blanket Implementations

[src]

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

[src]

pub fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

[src]

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

[src]

pub fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

[src]

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

[src]

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

Mutably borrows from an owned value. Read more

[src]

impl<T> From<T> for T

[src]

pub fn from(t: T) -> T

Performs the conversion.

[src]

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

[src]

pub fn into(self) -> U

Performs the conversion.

[src]

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

type Error = Infallible

The type returned in the event of a conversion error.

[src]

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

Performs the conversion.

[src]

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

type Error = >::Error

The type returned in the event of a conversion error.

[src]

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

Performs the conversion.

Struct fizyr_rpc::ReceivedRequestHandle[−][src]

Implementations

impl<Body> ReceivedRequestHandle<Body>

pub fn request_id(&self) -> u32

pub fn service_id(&self) -> i32

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

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

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

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

pub async fn send_error_response(&self, message: &str) -> Result<(), Error> where
Body: Body,

Trait Implementations

impl<Body> Debug for ReceivedRequestHandle<Body>

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

Auto Trait Implementations

impl<Body> !RefUnwindSafe for ReceivedRequestHandle<Body>

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

impl<Body> Sync for ReceivedRequestHandle<Body> where
Body: Send,

impl<Body> Unpin for ReceivedRequestHandle<Body>

impl<Body> !UnwindSafe for ReceivedRequestHandle<Body>

Blanket Implementations

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

pub fn type_id(&self) -> TypeId

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

pub fn borrow(&self) -> &T

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

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

impl<T> From<T> for T

pub fn from(t: T) -> T

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

pub fn into(self) -> U

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

type Error = Infallible

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

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

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

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

Struct fizyr_rpc::ReceivedRequestHandle[−][src]

Implementations

impl<Body> ReceivedRequestHandle<Body>

pub fn request_id(&self) -> u32

pub fn service_id(&self) -> i32

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

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

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

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

pub async fn send_error_response(&self, message: &str) -> Result<(), Error> where Body: Body,

Trait Implementations

impl<Body> Debug for ReceivedRequestHandle<Body>

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

Auto Trait Implementations

impl<Body> !RefUnwindSafe for ReceivedRequestHandle<Body>

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

impl<Body> Sync for ReceivedRequestHandle<Body> where Body: Send,

impl<Body> Unpin for ReceivedRequestHandle<Body>

impl<Body> !UnwindSafe for ReceivedRequestHandle<Body>

Blanket Implementations

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

pub fn type_id(&self) -> TypeId

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

pub fn borrow(&self) -> &T

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

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

impl<T> From<T> for T

pub fn from(t: T) -> T

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

pub fn into(self) -> U

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

type Error = Infallible

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

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

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

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

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

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

pub async fn send_error_response(&self, message: &str) -> Result<(), Error> where
Body: Body,

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

impl<Body> Sync for ReceivedRequestHandle<Body> where
Body: Send,

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

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

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

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

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

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