Struct OneShotCopier 

pub struct OneShotCopier { /* private fields */ }

OneShotCopier drives a single asynchronous copy step.

Implementations

impl OneShotCopier

pub fn new( fut: impl Future<Output = Result<Metadata>> + MaybeSend + 'static, ) -> Self

Create a new one-shot copier.

pub fn new_with<F, Fut>(factory: F) -> Self

where F: FnMut() -> Fut + 'static, Fut: Future<Output = Result<Metadata>> + MaybeSend + 'static,

Create a new one-shot copier with a future factory.

The factory will be called again if the previous future fails, allowing upper layers like retry to rerun the one-shot copy body.

pub fn completed() -> Self

Create a one-shot copier that has already completed.

Trait Implementations

impl Copy for OneShotCopier

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.

impl Send for OneShotCopier

Safety

On wasm targets, futures are local but still only polled through &mut self.

impl Sync for OneShotCopier

Safety

OneShotCopier is only accessed by &mut self.