Struct ChannelWriter 

pub struct ChannelWriter { /* private fields */ }

AsyncWrite over a channel of frames — the blocking stand-in for a socket write half.

Holds a mpsc::WeakSender, never a strong one, and that is load-bearing rather than tidiness. This adapter is typically owned by a task that is aborted, not joined, when the connection ends, so the moment its last strong sender drops is not a moment the owner controls. With only a weak handle here, WriterPumpGuard’s sender is the sole thing keeping the channel open, and dropping it ends the pump deterministically instead of whenever the runtime gets round to reaping an aborted task.

Trait Implementations

impl AsyncWrite for ChannelWriter

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

Frames are flushed by the writer pump as it takes them; there is no buffer here to push.

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

Attempt to write bytes from buf into the object.

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

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

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

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

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.