Struct DownloadStream 

pub struct DownloadStream { /* private fields */ }

A streaming download handle that yields data chunks as they are reconstructed.

Created by FileReconstructor::reconstruct_to_stream. The reconstruction task is spawned immediately but pauses until start is called (or the first next / blocking_next). Because the tokio::spawn happens at construction time, subsequent calls to start(), next(), and blocking_next() do not require a tokio runtime context.

Data is delivered by pulling items directly from the sequential writer’s internal queue, bypassing the synchronous writer thread entirely. Each call to blocking_next / next returns the next sequential chunk, or None when the download is complete. Any reconstruction error is surfaced on the call that would have returned the next chunk (or on the final None boundary) via the shared run state.

Implementations

impl DownloadStream

pub fn start(&mut self)

Unblocks the reconstruction task so it begins producing data.

If already started, this is a no-op. Called automatically on the first next / blocking_next.

This method is non-async and does not require a tokio runtime context.

pub fn blocking_next(&mut self) -> Result<Option<Bytes>>

Returns the next chunk of downloaded data, blocking the current thread until data is available.

Returns Ok(None) when the download is complete.

Panics

Panics if called from within an async runtime context (e.g. inside a tokio::spawn or async fn). Use from a regular thread or from tokio::task::spawn_blocking instead. For the async-safe variant, use next.

pub async fn next(&mut self) -> Result<Option<Bytes>>

Returns the next chunk of downloaded data asynchronously.

Returns Ok(None) when the download is complete or cancelled.

pub fn cancel(&mut self)

Cancels the in-progress (or not-yet-started) download.

Signals the shared run state so the reconstruction loop aborts at its next check point or select! branch, and closes the channel receiver. After calling this, subsequent calls to blocking_next / next will return Ok(None).

Trait Implementations

impl Drop for DownloadStream

fn drop(&mut self)

Executes the destructor for this type.