pub struct PeerWriteHandle<Body> { /* private fields */ }
Expand description

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§

source§

impl<Body> PeerWriteHandle<Body>

source

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

Send a new request to the remote peer.

source

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

Send a stream message to the remote peer.

source

pub fn close(&self)

Close the connection with the remote peer.

source

pub fn close_handle(&self) -> PeerCloseHandle<Body>

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.

source

pub fn same_peer(&self, other: &Self) -> bool

Check if this handle has the same underlying channel as other.

Trait Implementations§

source§

impl<Body> Clone for PeerWriteHandle<Body>

source§

fn clone(&self) -> Self

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl<Body> Debug for PeerWriteHandle<Body>

source§

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

Formats the value using the given formatter. Read more
source§

impl<Body> Drop for PeerWriteHandle<Body>

source§

fn drop(&mut self)

Executes the destructor for this type. Read more
source§

impl<F: Format> From<PeerWriteHandle<<F as Format>::Body>> for Client<F>

source§

fn from(other: PeerWriteHandle<F::Body>) -> Self

Converts to this type from the input type.

Auto Trait Implementations§

§

impl<Body> !RefUnwindSafe for PeerWriteHandle<Body>

§

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

§

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

§

impl<Body> Unpin for PeerWriteHandle<Body>

§

impl<Body> !UnwindSafe for PeerWriteHandle<Body>

Blanket Implementations§

source§

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

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

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

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

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

source§

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

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

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

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

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

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

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

Performs the conversion.
source§

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.
source§

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

Performs the conversion.