Struct ffsend_api::pipe::progress::ProgressPipe

pub struct ProgressPipe { /* fields omitted */ }

Methods

impl ProgressPipe

pub fn new(
    cur: u64,
    len: u64,
    reporter: Option<Arc<Mutex<dyn ProgressReporter>>>
) -> Self

Construct a new progress reporting pipe.

pub fn zero(
    len: u64,
    reporter: Option<Arc<Mutex<dyn ProgressReporter>>>
) -> Self

Construct a new progress reporting pipe.

Trait Implementations

impl Pipe for ProgressPipe

type Reader = ProgressReader

The wrapping reader type used for this pipe.

type Writer = ProgressWriter

The wrapping writer type used for this pipe.

fn pipe(&mut self, input: &[u8]) -> (usize, Option<Vec<u8>>)

Pipe bytes from input, monitor/transform it, return the output.

fn reader(self, inner: Box<dyn Read>) -> Self::Reader

Wrap the inner reader, bytes that are read are transformed through this pipe.

fn writer(self, inner: Box<dyn Write>) -> Self::Writer

Wrap the inner writer, bytes that are read are transformed through this pipe.

fn pipe_transparent(&self, input: &[u8]) -> (usize, Option<Vec<u8>>)

Transparently pipe input by immediately returning it.