Struct MemPusher 

pub struct MemPusher {
    pub receive: Arc<Mutex<Vec<u8>>>,
    /* private fields */
}

In-memory pusher for testing or buffer-based workflows.

All pushed data is stored in a shared Vec<u8> protected by a mutex. Supports random-access writes via copy_from_slice for non-sequential ranges.

Fields

receive: Arc<Mutex<Vec<u8>>>

Implementations

impl MemPusher

pub fn new() -> Self

pub fn with_capacity(capacity: usize) -> Self

Trait Implementations

impl Clone for MemPusher

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemPusher

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

Formats the value using the given formatter.

impl Default for MemPusher

fn default() -> MemPusher

Returns the “default value” for a type.

impl Pusher for MemPusher

type Error = !

fn set_listener(&mut self, cb: ProgressListener)

Install a callback that fires whenever a chunk has been successfully pushed to its destination.

fn push( &mut self, range: &ProgressEntry, content: Bytes, ) -> Result<(), (Self::Error, Bytes)>

Write content covering the given range to the destination.

fn flush(&mut self) -> Result<(), Self::Error>

Flush any buffered data to the destination.