Struct ProgressSink 

pub struct ProgressSink(/* private fields */);

Progress callback invoked by streaming put/get operations.

report(bytes_just_transferred) fires at chunk boundaries — one event per completed part / block on multipart uploads (both S3 and Azure above [multipart::MULTIPART_PUT_THRESHOLD]; issue #53), one event per ranged GET on multipart downloads, one event per body chunk on small-object reads, and a single end-of-transfer event on single-PUT uploads. Callers accumulate bytes_so_far themselves.

The callback runs on the backend’s task and may be invoked from a spawned worker, so it must be cheap and non-blocking. The LFS agent forwards report calls into an mpsc channel that the agent drains into protocol progress events.

Implementations

impl ProgressSink

pub fn new<F>(f: F) -> Self

where F: Fn(u64) + Send + Sync + 'static,

Build a sink from any cheap, thread-safe callback.

pub fn report(&self, bytes_amount: u64)

Report bytes_amount newly transferred bytes.

Trait Implementations

impl Clone for ProgressSink

fn clone(&self) -> ProgressSink

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ProgressSink

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.