Struct cros_async::sys::unix::async_types::AsyncTube

pub struct AsyncTube {
    inner: IoSource<Tube>,
}

Fields

inner: IoSource<Tube>

Implementations

impl AsyncTube

pub fn new(ex: &Executor, tube: Tube) -> Result<AsyncTube>

pub async fn next<T: DeserializeOwned>(&self) -> TubeResult<T>

pub async fn send<T: 'static + Serialize + Send + Sync>(
    &self,
    msg: T
) -> TubeResult<()>

Methods from Deref<Target = Tube>

pub fn try_clone_send_tube(&self) -> Result<SendTube, Error>

pub fn try_clone(&self) -> Result<Tube, Error>

👎Deprecated

DO NOT USE this method directly as it will become private soon (b/221484449). Use a directional Tube pair instead.

pub fn send<T>(&self, msg: &T) -> Result<(), Error>where
    T: Serialize,

pub fn recv<T>(&self) -> Result<T, Error>where
    T: DeserializeOwned,

pub fn set_send_timeout(&self, timeout: Option<Duration>) -> Result<(), Error>

pub fn set_recv_timeout(&self, timeout: Option<Duration>) -> Result<(), Error>

Trait Implementations

impl Deref for AsyncTube

type Target = Tube

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl From<AsyncTube> for Tube

fn from(at: AsyncTube) -> Tube

Converts to this type from the input type.