Struct ReaderLineBuffer 

pub struct ReaderLineBuffer<R: Read> {
    inner: Mutex<ReaderLineBufferInner<R>>,
}

A line-buffered reader backed by a circular buffer.

Reads lines from an io::Read source, stores them in a fixed-size circular buffer, and optionally calls a callback for each line.

Fields

inner: Mutex<ReaderLineBufferInner<R>>

Implementations

impl<R: Read> ReaderLineBuffer<R>

pub fn new(reader: R, max_lines: usize) -> Self

Create a new ReaderLineBuffer wrapping the given reader.

max_lines specifies the circular buffer capacity. If 0, defaults to 1000.

pub fn set_line_callback<F>(&self, callback: F)

where F: Fn(&str) + Send + 'static,

Set a callback that is invoked for each line read.

pub fn read_line(&self) -> Result<String>

Read the next line from the underlying reader.

Returns Ok(line) for each line, or Err(io::ErrorKind::UnexpectedEof) when the reader is exhausted.

pub fn read_all(&self)

Read all remaining lines until EOF.

pub fn is_done(&self) -> bool

Check if the reader has been fully consumed.

pub fn get_lines(&self) -> Vec<String>

Get a copy of all buffered lines.

pub fn get_line_count(&self) -> usize

Get the number of lines currently in the buffer.

pub fn get_total_line_count(&self) -> usize

Get the total number of lines read (may exceed buffer capacity).