Struct json_lines::accumulator::NewlinesAccumulator

pub struct NewlinesAccumulator<const N: usize> { /* private fields */ }

An accumulator used to collect chunked newline data and deserialize it.

This is often useful when you receive “parts” of the message at a time, for example when draining a serial port buffer that may not contain an entire uninterrupted message.

Implementations

impl<const N: usize> NewlinesAccumulator<N>

pub const fn new() -> Self

Create a new accumulator.

pub fn feed<'a, T>(&mut self, input: &'a [u8]) -> FeedResult<'a, T>where T: for<'de> Deserialize<'de>,

Appends data to the internal buffer and attempts to deserialize the accumulated data into T.

pub fn feed_ref<'de, 'a, T>(&'de mut self, input: &'a [u8]) -> FeedResult<'a, T>where T: Deserialize<'de>,

Appends data to the internal buffer and attempts to deserialize the accumulated data into T.

This differs from feed, as it allows the T to reference data within the internal buffer, but mutably borrows the accumulator for the lifetime of the deserialization. If T does not require the reference, the borrow of self ends at the end of the function.

Trait Implementations

impl<const N: usize> Format for NewlinesAccumulator<N>

fn format(&self, f: Formatter<'_>)

Writes the defmt representation of self to fmt.