Enum Writer

pub enum Writer {
    Cursor(Cursor<Vec<u8>>),
    Http(HttpWriter),
    Other(Box<dyn AsyncWrite + Unpin + Send + Sync>),
}

Variants

Cursor(Cursor<Vec<u8>>)

Http(HttpWriter)

Other(Box<dyn AsyncWrite + Unpin + Send + Sync>)

Implementations

impl Writer

pub fn from_tokio_writer<W>(w: W) -> Self

where W: AsyncWrite + Unpin + Send + Sync + 'static,

Create a Writer::Other from any AsyncWrite + Unpin + Send type.

pub fn from_cursor(w: Cursor<Vec<u8>>) -> Self

pub fn from_http(w: HttpWriter) -> Self

pub fn into_cursor_inner(self) -> Option<Vec<u8>>

pub fn as_cursor(&mut self) -> Option<&mut Cursor<Vec<u8>>>

pub fn as_http(&mut self) -> Option<&mut HttpWriter>

pub fn into_http(self) -> Option<HttpWriter>

pub fn into_cursor(self) -> Option<Cursor<Vec<u8>>>

Trait Implementations

impl AsyncWrite for Writer

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_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

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.