Struct Sender

pub struct Sender { /* private fields */ }

Sender of the simplex channel.

Cancellation safety

The Sender is cancel safe. If it is used as the event in a tokio::select! statement and some other branch completes first, it is guaranteed that no bytes were sent on this channel.

Shutdown

See Sender::poll_shutdown.

Trait Implementations

impl AsyncWrite for Sender

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize, Error>>

Errors

This method will return IoErrorKind::BrokenPipe if the channel has been closed.

fn poll_flush( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Errors

This method will return IoErrorKind::BrokenPipe if the channel has been closed.

fn poll_shutdown( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

After returns Poll::Ready, all the following call to Sender::poll_write and Sender::poll_flush will return error.

The Receiver can still be used to read remaining data until all bytes have been consumed.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, IoError>>

Like poll_write, except that it writes from a slice of buffers.

impl Debug for Sender

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for Sender

fn drop(&mut self)

This also wakes up the Receiver.