Struct BlockCopier 

pub struct BlockCopier<C: BlockCopy> { /* private fields */ }

BlockCopier implements oio::Copy based on block copy.

Implementations

impl<C: BlockCopy> BlockCopier<C>

pub fn new( executor: impl Into<Executor>, inner: C, source_content_length_hint: Option<u64>, copy_once_threshold: u64, block_size: u64, concurrent: usize, ) -> Self

Create a new BlockCopier.

Trait Implementations

impl<C> Copy for BlockCopier<C>

where C: BlockCopy,

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

Drive the copy operation forward.

async fn close(&mut self) -> Result<Metadata>

Close the copier and return metadata from the server-side completion response.

async fn abort(&mut self) -> Result<()>

Abort the pending copy operation.