Struct StreamWriter

pub struct StreamWriter {
    total_size: usize,
    bytes_sent: usize,
    chunk_size: usize,
    progress_callback: Option<ProgressCallback>,
    progress_interval: usize,
    bytes_since_progress: usize,
}

Streaming writer for sending data in chunks.

Used for POST/PUT requests with large bodies.

Fields

total_size: usize

Total bytes to send.

bytes_sent: usize

Bytes sent so far.

chunk_size: usize

Chunk size for sending.

progress_callback: Option<ProgressCallback>

Progress callback.

progress_interval: usize

Progress reporting interval.

bytes_since_progress: usize

Bytes since last progress report.

Implementations

impl StreamWriter

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

Create a new stream writer.

Arguments

• total_size - Total bytes to be sent
• chunk_size - Size of each chunk to send

pub fn set_progress_callback(&mut self, callback: ProgressCallback)

Set progress callback.

pub fn next_chunk<'a>(&mut self, source: &'a [u8]) -> Option<&'a [u8]>

Get next chunk to send from source data.

Returns slice of data for next chunk, or None if complete.

pub fn chunk_sent(&mut self, bytes: usize)

Mark chunk as sent.

pub fn is_complete(&self) -> bool

Check if all data has been sent.

pub fn bytes_sent(&self) -> usize

Get bytes sent so far.

pub fn remaining(&self) -> usize

Get remaining bytes.

pub fn progress_percent(&self) -> u8

Get progress percentage.

fn report_progress(&self)

Report progress via callback.

Trait Implementations

impl Debug for StreamWriter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.