Struct StdoutBuffer

pub struct StdoutBuffer<W: Write + Send + 'static> { /* private fields */ }

A writer that buffers content in memory for some duration before flushing the contents to an inner writer. After the duration elapses, any new bytes are written immediately to the inner writer. Calling flush() also immediately flushes the contents. Errors that occur when flushing on timeout are returned at the next write() or flush() call. Therefore, callers should make sure to call flush before the StdoutBuffer goes out of scope.

Implementations

impl<W: Write + Send + 'static> StdoutBuffer<W>

pub fn new(duration: Duration, writer: W, max_capacity: usize) -> Self

Crates new StdoutBuffer and starts the timer on log buffering. duration: Buffers log for this duration or till done() is called. sender: Channel to send logs on. max_capacity: Flush log if buffer size exceeds this value. This will not cancel the timer and all the logs would be flushed once timer expires.

Trait Implementations

impl<W: Write + Send + 'static> Write for StdoutBuffer<W>

fn flush(&mut self) -> Result<(), Error>

Flushes this output stream, ensuring that all intermediately buffered contents reach their destination.

fn write(&mut self, bytes: &[u8]) -> Result<usize, Error>

Writes a buffer into this writer, returning how many bytes were written.

fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> Result<usize, Error>

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

fn is_write_vectored(&self) -> bool

🔬This is a nightly-only experimental API. (can_vector)

Determines if this Writer has an efficient write_vectored implementation.

fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>

Attempts to write an entire buffer into this writer.

fn write_all_vectored(&mut self, bufs: &mut [IoSlice<'_>]) -> Result<(), Error>

🔬This is a nightly-only experimental API. (write_all_vectored)

Attempts to write multiple buffers into this writer.

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

Writes a formatted string into this writer, returning any error encountered.

fn by_ref(&mut self) -> &mut Self

where Self: Sized,

Creates a “by reference” adapter for this instance of Write.