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 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.