Struct AsyncArchiveReader 

pub struct AsyncArchiveReader<R> { /* private fields */ }

Available on crate feature async only.

Async-aware MPQ archive reader with resource protection

Implementations

impl<R: AsyncRead + AsyncSeek + Unpin + Send + 'static> AsyncArchiveReader<R>

pub fn new(reader: R, session_tracker: Arc<SessionTracker>) -> Self

Create a new async archive reader with default configuration

pub fn with_config( reader: R, config: AsyncConfig, session_tracker: Arc<SessionTracker>, ) -> Self

Create a new async archive reader with custom configuration

pub fn with_security_limits( reader: R, config: AsyncConfig, session_tracker: Arc<SessionTracker>, security_limits: SecurityLimits, ) -> Self

Create with custom security limits

pub async fn read_at(&self, offset: u64, buffer: &mut [u8]) -> Result<usize>

Read data at a specific offset with timeout and resource protection

pub async fn read_exact_at(&self, offset: u64, buffer: &mut [u8]) -> Result<()>

Read an exact number of bytes at a specific offset with security validation

pub async fn extract_files_concurrent( &self, file_requests: Vec<(String, u64, u64)>, ) -> Result<Vec<(String, Vec<u8>)>>

Perform multiple file extractions concurrently with bounded parallelism

pub fn create_decompression_monitor( &self, expected_size: u64, compression_method: u8, file_path: Option<&str>, ) -> Result<Arc<AsyncDecompressionMonitor>>

Create a decompression monitor for async operations

pub fn get_stats(&self) -> AsyncOperationStats

Get current async operation statistics

pub fn is_under_pressure(&self) -> bool

Check if the reader is under resource pressure

pub async fn shutdown(&self) -> Result<()>

Force cancellation of all pending operations (for cleanup)

Trait Implementations

impl<R: Debug> Debug for AsyncArchiveReader<R>

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

Formats the value using the given formatter.