Struct cros_async::sys::linux::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,

Sends a message via a Tube. The number of file descriptors that this method can send is limited to TUBE_MAX_FDS. If you want to send more descriptors, use send_with_max_fds instead.

pub fn send_with_max_fds<T>(&self, msg: &T, max_fds: usize) -> Result<(), Error>

where T: Serialize,

Sends a message with at most max_fds file descriptors via a Tube. Note that max_fds must not exceed SCM_SOCKET_MAX_FD_COUNT (= 253).

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

where T: DeserializeOwned,

Recieves a message from a Tube. If the sender sent file descriptors more than TUBE_MAX_FDS with send_with_max_fds, use recv_with_max_fds instead.

pub fn recv_with_max_fds<T>(&self, max_fds: usize) -> Result<T, Error>

where T: DeserializeOwned,

Recieves a message with at most max_fds file descriptors from a Tube.

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.