Struct ChunkStream 

pub struct ChunkStream<R> { /* private fields */ }

Stream processor for chunked data processing

Implementations

impl<R: Read> ChunkStream<R>

pub fn new(reader: R) -> Self

Create a new chunk stream with default chunk size

pub fn with_chunk_size(reader: R, chunk_size: usize) -> Self

Create a new chunk stream with custom chunk size

pub fn next_chunk(&mut self) -> Result<Option<Vec<u8>>>

Read the next chunk

Returns None when the end of the stream is reached.

pub fn process_all<F>(&mut self, callback: F) -> Result<()>

where F: FnMut(&[u8]) -> Result<()>,

Process all chunks with a callback