Struct FileReconstructor 

pub struct FileReconstructor { /* private fields */ }

Reconstructs a file from its content-addressed chunks by downloading xorb blocks and writing the reassembled data to an output. Supports byte range requests and uses memory-limited buffering with adaptive prefetching.

Implementations

impl FileReconstructor

pub fn new(client: &Arc<dyn Client>, file_hash: MerkleHash) -> Self

pub fn with_byte_range(self, byte_range: FileRange) -> Self

pub fn with_progress_updater( self, progress_updater: Arc<ItemProgressUpdater>, ) -> Self

pub fn with_chunk_cache(self, cache: Arc<dyn ChunkCache>) -> Self

pub fn with_config(self, config: impl AsRef<ReconstructionConfig>) -> Self

pub fn with_buffer_semaphore(self, semaphore: Arc<AdjustableSemaphore>) -> Self

Sets a custom buffer semaphore for controlling download buffer memory usage. This is primarily useful for testing scenarios where you want to control the timing of term fetches by limiting buffer capacity.

pub fn with_cancellation_token(self, token: CancellationToken) -> Self

Replaces the default cancellation token with the given one. This is used when external code needs to share the same token for coordinated cancellation.

pub async fn reconstruct_to_file( self, path: &Path, write_offset: Option<u64>, truncate_file: bool, ) -> Result<u64>

Reconstructs the file and writes it to the given path.

The file is opened with read/write access. When truncate_file is true the file is truncated to the reconstructed length; when false the file is left at its existing size, allowing multiple concurrent reconstructions to write to different regions of the same file.

When write_offset is Some(offset), writing begins at that byte position regardless of the byte range. When None, writing begins at the byte range start (or 0 for a full-file reconstruction).

pub async fn reconstruct_to_writer<W: Write + Send + 'static>( self, writer: W, ) -> Result<u64>

Reconstructs the file and writes it to the given writer.

The writer receives data starting from its current position (position 0 for a fresh writer), regardless of the byte range being reconstructed.

pub fn reconstruct_to_stream(self) -> DownloadStream

Reconstructs the file as a stream, returning a DownloadStream that yields data chunks as they become available.

The reconstruction task is spawned immediately but pauses on an internal tokio::sync::Notify until DownloadStream::start is called (or the first DownloadStream::next / DownloadStream::blocking_next).

Panics

Panics if called outside a tokio runtime context (the constructor uses tokio::spawn).

pub fn reconstruct_to_unordered_stream(self) -> UnorderedDownloadStream

Reconstructs the file as an unordered stream, returning an UnorderedDownloadStream that yields (offset, Bytes) chunks in whatever order they complete.

The reconstruction task is spawned immediately but pauses on an internal tokio::sync::Notify until UnorderedDownloadStream::start is called (or the first UnorderedDownloadStream::next / UnorderedDownloadStream::blocking_next).

Panics

Panics if called outside a tokio runtime context (the constructor uses tokio::spawn).