Struct fizyr_rpc::PeerReadHandle [−][src]
Handle to receive messages from a peer.
The read handle can be used to receive incoming requests and stream messages.
When all read and write handles are dropped, the peer loop is stopped. Any open requests will also be terminated.
Implementations
impl<Body> PeerReadHandle<Body>[src]
pub async fn next_message(&mut self) -> Result<Incoming<Body>, RecvMessageError>[src]
Get the next request or stream message from the remote peer.
Errors for invalid incoming messages are also reported by this function. For example: incoming update messages that are not associated with a received request will be reported as an error here.
pub fn close(&self)[src]
Close the connection with the remote peer.
pub fn close_handle(&self) -> PeerCloseHandle<Body>[src]
Make a close handle for the peer.
The close handle can be used to close the connection with the remote peer. It can be cloned and moved around independently.
Trait Implementations
impl<Body> Drop for PeerReadHandle<Body>[src]
Auto Trait Implementations
impl<Body> !RefUnwindSafe for PeerReadHandle<Body>[src]
impl<Body> Send for PeerReadHandle<Body> where
Body: Send, [src]
Body: Send,
impl<Body> Sync for PeerReadHandle<Body> where
Body: Send, [src]
Body: Send,
impl<Body> Unpin for PeerReadHandle<Body>[src]
impl<Body> !UnwindSafe for PeerReadHandle<Body>[src]
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
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>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,