[−][src]Struct fizyr_rpc::PeerWriteHandle
Handle to send messages to a peer.
The write handle can be used to send 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> PeerWriteHandle<Body>[src]
pub async fn send_request<'_>(
&'_ mut self,
service_id: i32,
body: impl Into<Body>
) -> Result<SentRequest<Body>, SendRequestError>[src]
&'_ mut self,
service_id: i32,
body: impl Into<Body>
) -> Result<SentRequest<Body>, SendRequestError>
Send a new request to the remote peer.
pub async fn send_stream<'_>(
&'_ mut self,
service_id: i32,
body: impl Into<Body>
) -> Result<(), WriteMessageError>[src]
&'_ mut self,
service_id: i32,
body: impl Into<Body>
) -> Result<(), WriteMessageError>
Send a stream message to the remote peer.
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> Clone for PeerWriteHandle<Body>[src]
fn clone(&self) -> Self[src]
fn clone_from(&mut self, source: &Self)1.0.0[src]
impl<Body> Drop for PeerWriteHandle<Body>[src]
Auto Trait Implementations
impl<Body> !RefUnwindSafe for PeerWriteHandle<Body>
impl<Body> Send for PeerWriteHandle<Body> where
Body: Send,
Body: Send,
impl<Body> Sync for PeerWriteHandle<Body> where
Body: Send,
Body: Send,
impl<Body> Unpin for PeerWriteHandle<Body>
impl<Body> !UnwindSafe for PeerWriteHandle<Body>
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> ToOwned for T where
T: Clone, [src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T[src]
pub fn clone_into(&self, target: &mut T)[src]
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>,