Struct JsonlReader 

pub struct JsonlReader<T> { /* private fields */ }

Reads JSONL records from a file, tracking the byte offset so that each poll only returns lines appended since the previous read.

Generic over any T: DeserializeOwned.

Implementations

impl<T: DeserializeOwned> JsonlReader<T>

pub fn new(path: impl Into<PathBuf>) -> Self

Create a new reader for the given path, starting at byte offset 0.

pub fn with_offset(path: impl Into<PathBuf>, offset: u64) -> Self

Create a new reader starting at the given byte offset.

Useful when restoring from persisted state — you can resume reading from where you left off without replaying old messages.

pub fn offset(&self) -> u64

Return the current byte offset.

pub fn set_offset(&mut self, offset: u64)

Set the byte offset (e.g. when restoring from persisted state).

pub fn skip_to_end(&mut self) -> Result<u64>

Skip to the end of the file so that subsequent polls only see new data.

Returns the new offset, or 0 if the file does not exist.

pub fn poll(&mut self) -> Result<Vec<T>>

Read any new lines appended since the last poll.

Returns a vector of successfully deserialized records. Malformed lines are silently skipped (the offset still advances past them).

Trait Implementations

impl<T: Debug> Debug for JsonlReader<T>

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

Formats the value using the given formatter.