Struct Async

pub struct Async<T> { /* private fields */ }

An async adapter for types implementing AsFd.

Implementations

impl<T> Async<T>

where T: AsFd,

pub fn new(t: T) -> Result<Self, Error>

Creates a new async adapter.

This takes ownership of the file description and duplicates the file descriptor. You should not modify the file description while this object is in use, otherwise the behavior is undefined.

impl<T> Async<T>

pub fn unwrap(self) -> T

Unwraps the underlying object.

Note that the underlying object is still non-blocking at this point.

pub async fn readable(&self) -> Result<(), Error>

Waits for the file description to become readable.

pub async fn writable(&self) -> Result<(), Error>

Waits for the file description to become writable.

Trait Implementations

impl<T> AsMut<T> for Async<T>

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

Converts this type into a mutable reference of the (usually inferred) input type.

impl<T> AsRef<T> for Async<T>

fn as_ref(&self) -> &T

Converts this type into a shared reference of the (usually inferred) input type.

impl<T> AsyncRead for Async<T>

where T: Read,

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

Attempt to read from the AsyncRead into buf.

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

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl<T> AsyncWrite for Async<T>

where T: Write,

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_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize>>

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

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_close(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>>

Attempt to close the object.

impl<T> Unpin for Async<T>