Trait ProgressCallback 

pub trait ProgressCallback: Send + Sync {
    // Required method
    fn on_progress(&self, decoded: usize, total: usize);
}

Callback invoked by the batch engine during long-running decodes. decoded is the number of events successfully decoded so far; total is the total count in the current batch.

Required Methods

fn on_progress(&self, decoded: usize, total: usize)

Implementors

impl<F: Fn(usize, usize) + Send + Sync> ProgressCallback for F

Blanket impl so closures can be used as progress callbacks.