Struct iroh_blobs::util::progress::FallibleProgressSliceWriter

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

A slice writer that adds a fallible 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. on_write must return an io::Result, and can abort the download by returning an error.

Implementations

impl<W: AsyncSliceWriter, F: Fn(u64, usize) -> Result<()> + 'static> FallibleProgressSliceWriter<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. on_write must return a future which resolves to an io::Result. If on_write returns an error, the download is aborted.

pub fn into_inner(self) -> W

Return the inner writer.

Trait Implementations

impl<W: AsyncSliceWriter + 'static, F: Fn(u64, usize) -> Result<()> + 'static> AsyncSliceWriter for FallibleProgressSliceWriter<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 FallibleProgressSliceWriter<W, F>

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

Formats the value using the given formatter.