Struct SequentialWriter 

pub struct SequentialWriter { /* private fields */ }

Writes data sequentially to an output stream from async data futures. Spawns async tasks to resolve futures and a background thread to perform blocking writes, allowing out-of-order future resolution with in-order writes.

Trait Implementations

impl DataWriter for SequentialWriter

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 source for the next block of data; this is a future that can be executing in the background. This must be the next one sequentially, otherwise it will error out.

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

where Self: 'async_trait,

Wait for the background writer to finish and all tasks to complete. Returns the number of bytes written.

impl Drop for SequentialWriter

fn drop(&mut self)

Executes the destructor for this type.