Struct ChunkedBuffer 

pub struct ChunkedBuffer { /* private fields */ }

A buffer that manages chunked data.

Implementations

impl ChunkedBuffer

pub fn new(chunk_size: usize, max_size: usize) -> Self

Create a new chunked buffer.

pub fn with_defaults() -> Self

Create a new chunked buffer with default settings.

pub fn calculate_chunks(&self, total_size: u64) -> usize

Calculate the number of chunks needed for a given size.

pub fn descriptor_for_index( &self, index: usize, total_size: u64, ) -> ChunkDescriptor

Get a chunk descriptor for a given index.

pub async fn push(&self, descriptor: ChunkDescriptor, data: Bytes) -> Result<()>

Push a chunk into the buffer.

pub async fn pop(&self) -> Result<Option<(ChunkDescriptor, Bytes)>>

Pop a chunk from the buffer.

pub async fn peek(&self) -> Result<Option<ChunkDescriptor>>

Peek at the next chunk without removing it.

pub async fn len(&self) -> usize

Get the number of chunks currently in the buffer.

pub async fn is_empty(&self) -> bool

Check if the buffer is empty.

pub async fn rebase_if_empty(&self, index: usize) -> bool

Move the write cursor to index, but only while the buffer is drained.

Self::push enforces a strictly sequential producer: a chunk is only accepted when its index equals the internal write cursor. A pull-based consumer such as crate::io::ChunkedReader serves a buffer miss with a direct read that deliberately bypasses this buffer, which leaves the write cursor lagging behind the stream and makes every later read-ahead push fail with StreamingError::InvalidOperation. Re-basing while the buffer holds nothing lets read-ahead resume at the consumer’s real position without weakening the ordering check for buffered chunks.

Returns true when the cursor was moved, false when the buffer still holds chunks (in which case re-basing would reorder them and is refused).

pub async fn size_bytes(&self) -> usize

Get the current buffer size in bytes.

pub async fn is_complete(&self) -> bool

Check if writing is complete.

pub async fn clear(&self)

Clear all chunks from the buffer.

pub async fn stats(&self) -> BufferStats

Get buffer statistics.