Struct EnhancedStreamingValidator 

pub struct EnhancedStreamingValidator { /* private fields */ }

Enhanced streaming validator with progress reporting and interruption support

Implementations

impl EnhancedStreamingValidator

pub fn new( config: ValidationConfig, streaming_config: StreamingValidationConfig, ) -> Self

Create new enhanced streaming validator

pub fn set_progress_callback<F>(&mut self, callback: F)

where F: Fn(&ValidationProgress) + Send + Sync + 'static,

Set progress callback function

pub fn interrupt(&self)

Request validation interruption

pub fn is_interrupted(&self) -> bool

Check if validation was interrupted

pub fn get_progress(&self) -> Option<&ValidationProgress>

Get current validation progress

pub async fn save_checkpoint<P: AsRef<Path>>( &self, checkpoint_path: P, ) -> TrackingResult<()>

Save validation checkpoint

pub async fn load_checkpoint<P: AsRef<Path>>( &mut self, checkpoint_path: P, ) -> TrackingResult<()>

Load validation checkpoint

pub async fn validate_stream_async<R>( &mut self, reader: R, total_size: Option<u64>, ) -> TrackingResult<ValidationResult>

where R: Read,

Enhanced streaming validation with AsyncRead support