Struct FileDownload 

pub struct FileDownload { /* private fields */ }

A file download in progress with true USB streaming.

This struct wraps the low-level ReceiveStream and provides convenient methods for tracking progress. Data is streamed directly from USB as chunks arrive, without buffering the entire file in memory.

Important

The MTP session is locked while this download is active. You must consume the entire download (or drop it) before calling other storage methods.

Example

let mut download = storage.download_stream(handle).await?;
println!("Downloading {} bytes...", download.size());

while let Some(chunk) = download.next_chunk().await {
    let bytes = chunk?;
    file.write_all(&bytes).await?;
    println!("Progress: {:.1}%", download.progress() * 100.0);
}

Implementations

impl FileDownload

pub fn size(&self) -> u64

Total file size in bytes.

pub fn bytes_received(&self) -> u64

Bytes received so far.

pub fn progress(&self) -> f64

Progress as a fraction (0.0 to 1.0).

pub async fn next_chunk(&mut self) -> Option<Result<Bytes, Error>>

Get the next chunk of data from USB.

Returns None when the download is complete.

pub async fn collect_with_progress<F>( self, on_progress: F, ) -> Result<Vec<u8>, Error>

where F: FnMut(Progress) -> ControlFlow<()>,

Consume the download and iterate with a progress callback.

Calls on_progress after each chunk. Return ControlFlow::Break(()) to cancel the download.

Example

let data = download.collect_with_progress(|progress| {
    println!("{:.1}%", progress.percent().unwrap_or(0.0));
    ControlFlow::Continue(())
}).await?;

pub async fn collect(self) -> Result<Vec<u8>, Error>

Collect all remaining data into a Vec<u8>.

This consumes the download and buffers all data in memory.