Struct MemPusher 

pub struct MemPusher {
    pub receive: Arc<Mutex<RawMutex, 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<RawMutex, Vec<u8>>>

The shared buffer the pusher writes into.

Implementations

impl MemPusher

pub fn new() -> MemPusher

Create an empty in-memory pusher.

pub fn with_capacity(capacity: usize) -> MemPusher

Create an in-memory pusher with a pre-allocated buffer of capacity bytes.

Trait Implementations

impl Clone for MemPusher

fn clone(&self) -> MemPusher

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<(), Error>

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 = !

Error produced while pushing.

fn set_listener(&mut self, cb: Box<dyn FnMut(Range<u64>) + Send>)

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

fn push( &mut self, range: &Range<u64>, content: Bytes, ) -> Result<(), (<MemPusher as Pusher>::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.