Struct RouterAsyncReqChannel

pub struct RouterAsyncReqChannel<'r> { /* private fields */ }

A request channel.

Implementations

impl<'r> RouterAsyncReqChannel<'r>

pub fn tag_noexpire(&mut self) -> Result<()>

Set the tag to not expire. That allows multiple calls to send().

async_drop must be called prior to drop.

pub async fn async_drop(self)

This must be called prior to drop whenever tag_noexpire() is used.

A workaround until async drop is implemented in Rust itself. https://github.com/rust-lang/rust/issues/126482

Trait Implementations

impl AsyncReqChannel for RouterAsyncReqChannel<'_>

A request channel

Created with Router::req().

async fn send_vectored( &mut self, typ: MsgType, integrity_check: MsgIC, bufs: &[&[u8]], ) -> Result<()>

Send a message.

This will async block until the message has been enqueued to the physical port. Note that it will return failure immediately if the MCTP stack has no available tags, that behaviour may need changing in future.

Subsequent calls will fail unless tag_noexpire() was performed.

async fn recv<'f>( &mut self, buf: &'f mut [u8], ) -> Result<(MsgType, MsgIC, &'f mut [u8])>

fn remote_eid(&self) -> Eid

Return the remote Endpoint ID

fn send( &mut self, typ: MsgType, buf: &[u8], ) -> impl Future<Output = Result<(), Error>>

impl Drop for RouterAsyncReqChannel<'_>

fn drop(&mut self)

Executes the destructor for this type.