Struct AsyncStreamingStats 

pub struct AsyncStreamingStats {
    pub bytes_processed: u64,
    pub chunks_processed: usize,
    pub lines_processed: usize,
    pub processing_time_ms: f64,
    pub concurrent_operations: usize,
    pub avg_speed_mbps: f64,
    pub peak_memory_usage: usize,
}

Async statistics for tracking async operations

Fields

bytes_processed: u64

Total bytes processed

chunks_processed: usize

Total chunks processed

lines_processed: usize

Total lines processed (for line-based readers)

processing_time_ms: f64

Processing time in milliseconds

concurrent_operations: usize

Number of concurrent operations

avg_speed_mbps: f64

Average processing speed in MB/s

peak_memory_usage: usize

Peak memory usage in bytes

Implementations

impl AsyncStreamingStats

pub fn new() -> Self

Create new async streaming statistics

pub fn update_chunk(&mut self, bytes: u64, processing_time_ms: f64)

Update statistics with chunk information

pub fn update_lines(&mut self, lines: usize)

Update statistics with line information

pub fn update_concurrency(&mut self, count: usize)

Update concurrent operations count

pub fn update_memory_usage(&mut self, usage: usize)

Update peak memory usage

pub fn summary(&self) -> String

Get a summary string of the async statistics

Trait Implementations

impl Clone for AsyncStreamingStats

fn clone(&self) -> AsyncStreamingStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AsyncStreamingStats

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

Formats the value using the given formatter.

impl Default for AsyncStreamingStats

fn default() -> AsyncStreamingStats

Returns the “default value” for a type.