Struct re_log_encoding::decoder::stream::ChunkBuffer

struct ChunkBuffer {
    queue: VecDeque<Cursor<Vec<u8>>>,
    buffer: Vec<u8>,
    buffer_fill: usize,
}

Fields

queue: VecDeque<Cursor<Vec<u8>>>

Any incoming chunks are queued until they are emptied

buffer: Vec<u8>

This buffer is used as scratch space for any read bytes, so that we can return a contiguous slice from try_read.

buffer_fill: usize

How many bytes of valid data are currently in self.buffer.

Implementations

impl ChunkBuffer

fn new() -> Self

fn push(&mut self, chunk: Vec<u8>)

fn try_read(&mut self, n: usize) -> Option<&[u8]>

Attempt to read exactly n bytes out of the queued chunks.

Returns None if there is not enough data to return a slice of n bytes.

NOTE: try_read must be called with the same n until it returns Some, otherwise this will discard any previously buffered data.