Struct OwnedWriteHalf

pub struct OwnedWriteHalf(/* private fields */);

Available on Unix and crate feature tokio_support only.

Owned write half of a UdStream, created by .into_split().

Implementations

impl OwnedWriteHalf

pub fn reunite_with(self, read: OwnedReadHalf) -> Result<UdStream, ReuniteError>

Attempts to put two owned halves of a stream back together and recover the original stream. Succeeds only if the two halves originated from the same call to .into_split().

pub fn get_peer_credentials(&self) -> Result<ucred>

Available on Linux and (GNU or musl or target_env="musleabi" or target_env="musleabihf"), or Emscripten, or Redox, or Haiku only.

Fetches the credentials of the other end of the connection without using ancillary data. The returned structure contains the process identifier, user identifier and group identifier of the peer.

pub fn shutdown(&self) -> Result<()>

Shuts down the write half.

Attempting to call this method multiple times may return Ok(()) every time or it may return an error the second time it is called, depending on the platform. You must either avoid using the same value twice or ignore the error entirely.

pub fn into_tokio(self) -> TokioUdStreamOwnedWriteHalf

Unwraps into Tokio’s corresponding type. This is a zero-cost operation.

pub fn from_tokio(tokio: TokioUdStreamOwnedWriteHalf) -> Self

Wraps Tokio’s corresponding type. This is a zero-cost operation.

Trait Implementations

impl AsyncWrite for OwnedWriteHalf

fn poll_shutdown( self: Pin<&mut Self>, _: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Finishes immediately. See the .shutdown() method.

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl AsyncWrite for OwnedWriteHalf

fn poll_close( self: Pin<&mut Self>, _: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Finishes immediately. See the .shutdown() method.

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempt to flush the object, ensuring that any buffered data reach their destination.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from bufs into the object using vectored IO operations.

impl Debug for OwnedWriteHalf

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

Formats the value using the given formatter.

impl From<OwnedWriteHalf> for TokioUdStreamOwnedWriteHalf

fn from(x: OwnedWriteHalf) -> Self

Converts to this type from the input type.

impl From<OwnedWriteHalf> for OwnedWriteHalf

fn from(tokio: TokioUdStreamOwnedWriteHalf) -> Self

Converts to this type from the input type.