Struct geng::prelude::futures::io::LineWriter

pub struct LineWriter<W>
where
    W: AsyncWrite,
{ /* private fields */ }

Wrap a writer, like BufWriter does, but prioritizes buffering lines

This was written based on std::io::LineWriter which goes into further details explaining the code.

Buffering is actually done using BufWriter. This class will leverage BufWriter to write on-each-line.

Implementations

impl<W> LineWriter<W>

where W: AsyncWrite,

pub fn new(inner: W) -> LineWriter<W>

Create a new LineWriter with default buffer capacity. The default is currently 1KB which was taken from std::io::LineWriter

pub fn with_capacity(capacity: usize, inner: W) -> LineWriter<W>

Creates a new LineWriter with the specified buffer capacity.

pub fn buffer(&self) -> &[u8]

Returns a reference to buf_writer’s internally buffered data.

pub fn get_ref(&self) -> &W

Acquires a reference to the underlying sink or stream that this combinator is pulling from.

Trait Implementations

impl<W> AsyncWrite for LineWriter<W>

where W: AsyncWrite,

fn poll_flush( self: Pin<&mut LineWriter<W>>, cx: &mut Context<'_> ) -> Poll<Result<(), Error>>

Forward to buf_writer ’s BufWriter::poll_flush()

fn poll_close( self: Pin<&mut LineWriter<W>>, cx: &mut Context<'_> ) -> Poll<Result<(), Error>>

Forward to buf_writer ’s BufWriter::poll_close()

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

Attempt to write bytes from buf into the object.

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

Attempt to write bytes from bufs into the object using vectored IO operations.

impl<W> Debug for LineWriter<W>

where W: Debug + AsyncWrite,

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

Formats the value using the given formatter.

impl<'__pin, W> Unpin for LineWriter<W>

where W: AsyncWrite, __Origin<'__pin, W>: Unpin,