Struct hyper_socket::UnixSocketConnection

pub struct UnixSocketConnection(_);

A wrapper around Tokio's UnixStream type, implementing Connection.

Methods from Deref<Target = UnixStream>

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

Returns the socket address of the local half of this connection.

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

Returns the socket address of the remote half of this connection.

pub fn peer_cred(&self) -> Result<UCred, Error>

Returns effective credentials of the process which called connect or pair.

pub fn take_error(&self) -> Result<Option<Error>, Error>

Returns the value of the SO_ERROR option.

pub fn shutdown(&self, how: Shutdown) -> Result<(), Error>

Shuts down the read, write, or both halves of this connection.

This function will cause all pending and future I/O calls on the specified portions to immediately return with an appropriate value (see the documentation of Shutdown).

pub fn split(&mut self) -> (ReadHalf, WriteHalf)

Split a UnixStream into a read half and a write half, which can be used to read and write the stream concurrently.

See the module level documenation of split for more details.

Trait Implementations

impl AsyncRead for UnixSocketConnection

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

Attempt to read from the AsyncRead into buf.

unsafe fn prepare_uninitialized_buffer(
    &self,
    buf: &mut [MaybeUninit<u8>]
) -> bool

Prepares an uninitialized buffer to be safe to pass to read. Returns true if the supplied buffer was zeroed out.

fn poll_read_buf<B>(
    self: Pin<&mut Self>,
    cx: &mut Context,
    buf: &mut B
) -> Poll<Result<usize, Error>> where
    B: BufMut, 

Pull some bytes from this source into the specified BufMut, returning how many bytes were read.

impl AsyncWrite for UnixSocketConnection

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<()>>

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

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

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_buf<B>(
    self: Pin<&mut Self>,
    cx: &mut Context,
    buf: &mut B
) -> Poll<Result<usize, Error>> where
    B: Buf, 

Write a Buf into this value, returning how many bytes were written.

impl Connection for UnixSocketConnection

fn connected(&self) -> Connected

Return metadata describing the connection.

impl Deref for UnixSocketConnection

type Target = UnixStream

The resulting type after dereferencing.

fn deref(&self) -> &UnixStream

Dereferences the value.

impl DerefMut for UnixSocketConnection

fn deref_mut(&mut self) -> &mut UnixStream

Mutably dereferences the value.