Struct AsyncChecksumAdapter 

pub struct AsyncChecksumAdapter<T: ChecksumService + 'static> { /* private fields */ }

Async adapter for ChecksumService

Wraps a synchronous ChecksumService implementation and provides async methods that execute the sync operations in a way that doesn’t block the async runtime.

Design Rationale

• Domain Purity: Domain traits remain sync and portable
• Infrastructure Flexibility: Async execution is an implementation detail
• Non-Blocking: Uses spawn_blocking for CPU-intensive operations
• Zero-Cost When Sync: No overhead if used in sync contexts

Implementations

impl<T: ChecksumService + 'static> AsyncChecksumAdapter<T>

pub fn new(service: Arc<T>) -> Self

Creates a new async adapter wrapping a sync checksum service

pub async fn process_chunk_async( &self, chunk: FileChunk, context: &mut ProcessingContext, stage_name: &str, ) -> Result<FileChunk, PipelineError>

Processes a chunk asynchronously, updating the running checksum

Executes the synchronous process operation in a blocking task pool to avoid blocking the async runtime.

pub async fn process_chunks_parallel( &self, chunks: Vec<FileChunk>, context: &mut ProcessingContext, stage_name: &str, ) -> Result<Vec<FileChunk>, PipelineError>

Processes multiple chunks in parallel (infrastructure concern)

This method demonstrates how parallelization is an infrastructure concern, not a domain concern. The domain just defines process_chunk.

pub fn get_checksum( &self, context: &ProcessingContext, stage_name: &str, ) -> Option<String>

Gets the final checksum value (sync operation)

Trait Implementations

impl<T: ChecksumService + 'static> Clone for AsyncChecksumAdapter<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.