Struct iroh_blobs::util::progress::ProgressSliceWriter

pub struct ProgressSliceWriter<W, F>(/* private fields */);

A slice writer that adds a synchronous progress callback.

This wraps any AsyncSliceWriter, passes through all operations to the inner writer, and calls the passed on_write callback whenever data is written.

Implementations

impl<W: AsyncSliceWriter, F: FnMut(u64)> ProgressSliceWriter<W, F>

pub fn new(inner: W, on_write: F) -> Self

Create a new ProgressSliceWriter from an inner writer and a progress callback

The on_write function is called for each write, with the offset as the first and the length of the data as the second param.

pub fn into_inner(self) -> W

Return the inner writer

Trait Implementations

impl<W: AsyncSliceWriter + 'static, F: FnMut(u64, usize) + 'static> AsyncSliceWriter for ProgressSliceWriter<W, F>

async fn write_bytes_at(&mut self, offset: u64, data: Bytes) -> Result<()>

Write the entire Bytes at the given position.

async fn write_at(&mut self, offset: u64, data: &[u8]) -> Result<()>

Write the entire slice at the given position.

async fn sync(&mut self) -> Result<()>

Sync any buffers to the underlying storage.

async fn set_len(&mut self, size: u64) -> Result<()>

Set the length of the underlying storage.

impl<W: Debug, F: Debug> Debug for ProgressSliceWriter<W, F>

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

Formats the value using the given formatter.