Struct AsyncDuplex

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

A wrapper type around some “handle” that we want to perform asynchronous operations on, where that handle must implement AsyncDuplexSetup.

Implementations

impl<T: AsyncDuplexSetup> AsyncDuplex<T>

pub fn new(handle: T) -> Self

Construct a new Async<T>.

pub fn into_inner(self) -> T

Consume the wrapper and return the underlying handle.

pub fn get_ref(&self) -> &T

Return a reference to the underlying handle.

pub async fn read_with<R>( &self, op: impl FnMut(&T) -> Result<R, T::ReadError>, ) -> Result<R, T::ReadError>

Asynchronously run a read-like operation that will sleep if not ready. The closure to run must return Result<_, T::ReadError>, and should return Err(T::READ_WOULD_BLOCK) if the operation is not ready.

pub async fn write_with<R>( &self, op: impl FnMut(&T) -> Result<R, T::WriteError>, ) -> Result<R, T::WriteError>

Asynchronously run a write-like operation that will sleep if not ready. The closure to run must return Result<_, T::WriteError>, and should return Err(T::WRITE_WOULD_BLOCK) if the operation is not ready.

Trait Implementations

impl<T> Drop for AsyncDuplex<T>

fn drop(&mut self)

Executes the destructor for this type.