Struct UnorderedWriter 

pub struct UnorderedWriter { /* private fields */ }

Writer that delivers completed data terms in arbitrary order.

Each call to set_next_term_data_source spawns a task (tracked via a JoinSet) that resolves the data future and sends the result through an mpsc channel. The consumer (typically an UnorderedDownloadStream) reads from the receiver end and gets items in whatever order tasks complete.

The consumer stream holds only Arc<UnorderedWriterProgress>, not the writer itself, so the writer’s channel sender is dropped naturally when the reconstruction task finishes and consumes the writer via finish().

Trait Implementations

impl DataWriter for UnorderedWriter

fn set_next_term_data_source<'life0, 'async_trait>( &'life0 mut self, byte_range: FileRange, permit: Option<AdjustableSemaphorePermit>, data_future: Pin<Box<dyn Future<Output = Result<Bytes>> + Send + 'static>>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sets the data source for the next sequential term.

fn finish<'async_trait>( self: Box<Self>, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

where Self: 'async_trait,

Consumes the writer, waits until all data has been written, and returns the number of bytes written. Dropping the writer without calling finish cancels the reconstruction via the shared run state.

impl Drop for UnorderedWriter

fn drop(&mut self)

Executes the destructor for this type.