Struct OwnedWriteHalf

#[repr(transparent)]
pub struct OwnedWriteHalf<T>(pub Rc<UnsafeCell<T>>)
where
    T: AsyncWriteRent;

Owned Write Half Part

Tuple Fields

0: Rc<UnsafeCell<T>>

Implementations

impl<T> OwnedWriteHalf<T>

where T: AsyncWriteRent,

pub fn reunite(self, other: OwnedReadHalf<T>) -> Result<T, ReuniteError<T>>

reunite read half

impl OwnedWriteHalf<TcpStream>

pub fn peer_addr(&self) -> Result<SocketAddr>

Returns the remote address that this stream is connected to.

pub fn local_addr(&self) -> Result<SocketAddr>

Returns the local address that this stream is bound to.

Trait Implementations

impl<Inner> AsyncWriteRent for OwnedWriteHalf<Inner>

where Inner: AsyncWriteRent,

fn write<T: IoBuf>( &mut self, buf: T, ) -> impl Future<Output = BufResult<usize, T>>

Writes the contents of a buffer into this writer, returning the number of bytes written.

fn writev<T: IoVecBuf>( &mut self, buf_vec: T, ) -> impl Future<Output = BufResult<usize, T>>

This function attempts to write the entire contents of buf_vec, but the write may not fully succeed, and it might also result in an error. The bytes will be written starting at the specified offset.

fn flush(&mut self) -> impl Future<Output = Result<()>>

Flushes this output stream, ensuring that all buffered content is successfully written to its destination.

fn shutdown(&mut self) -> impl Future<Output = Result<()>>

Shuts down the output stream, ensuring that the value can be cleanly dropped.

impl<Inner> CancelableAsyncWriteRent for OwnedWriteHalf<Inner>

where Inner: CancelableAsyncWriteRent,

fn cancelable_write<T: IoBuf>( &mut self, buf: T, c: CancelHandle, ) -> impl Future<Output = BufResult<usize, T>>

Same as write(2)

fn cancelable_writev<T: IoVecBuf>( &mut self, buf_vec: T, c: CancelHandle, ) -> impl Future<Output = BufResult<usize, T>>

Same as writev(2)

fn cancelable_flush( &mut self, c: CancelHandle, ) -> impl Future<Output = Result<()>>

Flush buffered data if needed

fn cancelable_shutdown( &mut self, c: CancelHandle, ) -> impl Future<Output = Result<()>>

Same as shutdown

impl<T> Debug for OwnedWriteHalf<T>

where T: AsyncWriteRent + Debug,

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

Formats the value using the given formatter.

impl<T> Drop for OwnedWriteHalf<T>

where T: AsyncWriteRent,

fn drop(&mut self)

Executes the destructor for this type.