Struct 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,