Struct StreamingProgress 

pub struct StreamingProgress {
    pub bytes_processed: usize,
    pub items_processed: usize,
    pub errors_encountered: usize,
    pub total_bytes: Option<usize>,
    pub items_per_second: Option<f64>,
}

Progress information for async operations

Fields

bytes_processed: usize

Total bytes processed

items_processed: usize

Total items (quads/triples) processed

errors_encountered: usize

Errors encountered (if error tolerance is enabled)

total_bytes: Option<usize>

Estimated total bytes (if known)

items_per_second: Option<f64>

Processing rate (items per second)

Implementations

impl StreamingProgress

pub fn new() -> Self

Create new progress info

pub fn completion_percentage(&self) -> Option<f64>

Calculate completion percentage if total size is known

Trait Implementations

impl Clone for StreamingProgress

fn clone(&self) -> StreamingProgress

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamingProgress

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

Formats the value using the given formatter.

impl Default for StreamingProgress

fn default() -> Self

Returns the “default value” for a type.