Struct MmapFilePusher 

pub struct MmapFilePusher { /* private fields */ }

File pusher using memory-mapped I/O for zero-copy writes.

Delegates writes to the OS via MmapMut. The file size is fixed at construction time via file.set_len(size). On flush, if sync_all is true an fsync is performed; otherwise an async flush is issued.

Implementations

impl MmapFilePusher

pub async fn new( file: &File, size: u64, sync_all: bool, ) -> Result<MmapFilePusher, Error>

Errors

1. Returns an error if fs::set_len fails.
2. Returns an error if MmapMut::map_mut fails.

Trait Implementations

impl Debug for MmapFilePusher

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

Formats the value using the given formatter.

impl Pusher for MmapFilePusher

type Error = 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>, bytes: Bytes, ) -> Result<(), (<MmapFilePusher as Pusher>::Error, Bytes)>

Write content covering the given range to the destination.

fn flush(&mut self) -> Result<(), <MmapFilePusher as Pusher>::Error>

Flush any buffered data to the destination.