Struct StreamingFileWriter 

pub struct StreamingFileWriter { /* private fields */ }

Async buffered disk writer that streams data directly to a temporary .lanflare-part file while concurrently calculating the SHA-256 hash incrementally in memory.

Implementations

impl StreamingFileWriter

pub async fn create( target_path: impl Into<PathBuf>, expected_size: Option<u64>, expected_sha256: Option<String>, ) -> Result<Self, StorageError>

Creates a new streaming file writer. Overwrites target file if it already exists.

pub async fn create_with_overwrite( target_path: impl Into<PathBuf>, expected_size: Option<u64>, expected_sha256: Option<String>, allow_overwrite: bool, ) -> Result<Self, StorageError>

Creates a new streaming file writer with optional overwrite protection.

pub async fn create_with_capacity( target_path: impl Into<PathBuf>, expected_size: Option<u64>, expected_sha256: Option<String>, buffer_capacity: usize, ) -> Result<Self, StorageError>

Creates a new streaming file writer with custom buffer capacity.

pub fn target_path(&self) -> &Path

Returns the target destination path.

pub fn temp_path(&self) -> &Path

Returns the temporary file path currently being written to.

pub fn bytes_written(&self) -> u64

Returns the total number of bytes written so far.

pub fn expected_size(&self) -> Option<u64>

Returns the expected size in bytes, if specified.

pub fn expected_sha256(&self) -> Option<&str>

Returns the expected SHA-256 hash, if specified.

pub async fn write_chunk(&mut self, chunk: &[u8]) -> Result<(), StorageError>

Writes a single chunk to disk and updates the running SHA-256 digest.

pub async fn write_all_from_stream<S, B, E>( &mut self, stream: S, ) -> Result<(), StorageError>

where S: Stream<Item = Result<B, E>> + Unpin, B: AsRef<[u8]>, E: Display,

Streams chunks from an asynchronous stream and writes them directly to disk.

pub async fn write_all_from_reader<R>( &mut self, reader: R, ) -> Result<(), StorageError>

where R: AsyncRead + Unpin,

Reads all data from an AsyncRead source and writes it to disk.

pub async fn commit(self) -> Result<StorageCommitResult, StorageError>

Flushes data, verifies size and SHA-256 checksum, and atomically renames the temporary .lanflare-part file to the final destination path.

pub async fn abort(self) -> Result<(), StorageError>

Aborts writing and immediately removes the temporary file from disk.

Trait Implementations

impl Debug for StreamingFileWriter

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

Formats the value using the given formatter.

impl Drop for StreamingFileWriter

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.