Struct StreamWriter 

pub struct StreamWriter {
    pub buffer: Vec<u8>,
    pub buffer_size: usize,
    pub flush_interval: f64,
    pub last_flush: f64,
    pub total_written: usize,
    pub flushed: Vec<u8>,
}

Async-style streaming writer with buffered writes and flush interval.

Fields

buffer: Vec<u8>

Output buffer.

buffer_size: usize

Maximum buffer size before auto-flush.

flush_interval: f64

Flush interval in seconds.

last_flush: f64

Last flush time.

total_written: usize

Total bytes written.

flushed: Vec<u8>

Flushed data (in-memory output).

Implementations

impl StreamWriter

pub fn new(buffer_size: usize, flush_interval: f64) -> Self

Create a new stream writer.

pub fn write(&mut self, data: &[u8])

Write bytes to buffer.

pub fn write_f64(&mut self, v: f64)

Write a f64 value.

pub fn write_u32(&mut self, v: u32)

Write a u32 value.

pub fn flush(&mut self)

Flush buffer to flushed storage.

pub fn maybe_flush(&mut self, current_time: f64)

Check and flush if interval elapsed.

pub fn flushed_bytes(&self) -> usize

Total flushed bytes.

Trait Implementations

impl Debug for StreamWriter

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

Formats the value using the given formatter.