Struct MessageWriteHalf

pub struct MessageWriteHalf<'a, M: RingMem> { /* private fields */ }

The write half of a pipe.

Implementations

impl<M: RingMem> MessageWriteHalf<'_, M>

pub fn poll_ready( &mut self, cx: &mut Context<'_>, send_size: usize, ) -> Poll<Result<()>>

Polls the outgoing ring for the ability to send a packet of size send_size.

send_size can be computed by calling try_write and extracting the size from TryReadError::Full(send_size).

pub fn poll_empty(&mut self, cx: &mut Context<'_>) -> Poll<Result<()>>

Polls the outgoing ring for being completely empty, indicating that the other endpoint has read everything.

pub async fn wait_ready(&mut self, send_size: usize) -> Result<()>

Waits until there is enough space in the ring to send a packet of size send_size.

send_size can be computed by calling try_write and extracting the size from TryReadError::Full(send_size).

pub async fn wait_empty(&mut self) -> Result<()>

Waits until the ring is completely empty, indicating that the other endpoint has read everything.

pub fn try_send(&mut self, buf: &[u8]) -> Result<()>

Tries to send a datagram, failing with io::ErrorKind::WouldBlock if there is not enough space in the ring.

pub fn try_send_vectored(&mut self, bufs: &[IoSlice<'_>]) -> Result<()>

Tries to send a datagram, failing with io::ErrorKind::WouldBlock if there is not enough space in the ring.

Trait Implementations

impl<M: RingMem> AsyncSend for MessageWriteHalf<'_, M>

fn poll_send( &mut self, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<()>>

Polls to send a datagram given by bufs.