Struct ProgressPipe

pub struct ProgressPipe { /* private fields */ }

Implementations

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 = PipeReader<ProgressPipe>

The wrapping reader type used for this pipe.

type Writer = PipeWriter<ProgressPipe>

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.