Struct parallel_disk_usage::reporter::progress_and_error_reporter::ProgressAndErrorReporter
source · [−]pub struct ProgressAndErrorReporter<Data, ReportError> where
Data: Size + Send + Sync,
ReportError: Fn(ErrorReport<'_>) + Sync,
u64: Into<Data>, { /* private fields */ }
Expand description
Store progress information and call report function on said information.
NOTE: If an error occurred, report_error
would be called before report_progress
.
Implementations
sourceimpl<Data, ReportError> ProgressAndErrorReporter<Data, ReportError> where
Data: Size + Send + Sync,
ReportError: Fn(ErrorReport<'_>) + Sync,
u64: Into<Data>,
impl<Data, ReportError> ProgressAndErrorReporter<Data, ReportError> where
Data: Size + Send + Sync,
ReportError: Fn(ErrorReport<'_>) + Sync,
u64: Into<Data>,
sourcepub fn new<ReportProgress>(
report_progress: ReportProgress,
progress_report_interval: Duration,
report_error: ReportError
) -> Self where
ProgressReport<Data>: Default + 'static,
ReportProgress: Fn(ProgressReport<Data>) + Send + Sync + 'static,
pub fn new<ReportProgress>(
report_progress: ReportProgress,
progress_report_interval: Duration,
report_error: ReportError
) -> Self where
ProgressReport<Data>: Default + 'static,
ReportProgress: Fn(ProgressReport<Data>) + Send + Sync + 'static,
Create a new ProgressAndErrorReporter
from a report function.
sourcepub fn stop_progress_reporter(&self)
pub fn stop_progress_reporter(&self)
Stop the thread that reports progress.
This function would be automatically invoked once the value is dropped.
Trait Implementations
sourceimpl<Data: Debug, ReportError: Debug> Debug for ProgressAndErrorReporter<Data, ReportError> where
Data: Size + Send + Sync,
ReportError: Fn(ErrorReport<'_>) + Sync,
u64: Into<Data>,
impl<Data: Debug, ReportError: Debug> Debug for ProgressAndErrorReporter<Data, ReportError> where
Data: Size + Send + Sync,
ReportError: Fn(ErrorReport<'_>) + Sync,
u64: Into<Data>,
sourceimpl<Data, ReportError> ParallelReporter<Data> for ProgressAndErrorReporter<Data, ReportError> where
Data: Size + Into<u64> + Send + Sync,
ReportError: Fn(ErrorReport<'_>) + Sync,
u64: Into<Data>,
impl<Data, ReportError> ParallelReporter<Data> for ProgressAndErrorReporter<Data, ReportError> where
Data: Size + Into<u64> + Send + Sync,
ReportError: Fn(ErrorReport<'_>) + Sync,
u64: Into<Data>,
type DestructionError = Box<dyn Any + Send + 'static>
type DestructionError = Box<dyn Any + Send + 'static>
Error type of the destroy
method.
sourcefn destroy(self) -> Result<(), Self::DestructionError>
fn destroy(self) -> Result<(), Self::DestructionError>
Stop all threads.
Auto Trait Implementations
impl<Data, ReportError> !RefUnwindSafe for ProgressAndErrorReporter<Data, ReportError>
impl<Data, ReportError> Send for ProgressAndErrorReporter<Data, ReportError> where
ReportError: Send,
impl<Data, ReportError> Sync for ProgressAndErrorReporter<Data, ReportError>
impl<Data, ReportError> Unpin for ProgressAndErrorReporter<Data, ReportError> where
Data: Unpin,
ReportError: Unpin,
impl<Data, ReportError> !UnwindSafe for ProgressAndErrorReporter<Data, ReportError>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcepub fn borrow_mut(&mut self) -> &mut T
pub fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<X> Pipe for X
impl<X> Pipe for X
sourcefn pipe<Return, Function>(self, f: Function) -> Return where
Function: FnOnce(Self) -> Return,
fn pipe<Return, Function>(self, f: Function) -> Return where
Function: FnOnce(Self) -> Return,
Apply f
to self
. Read more
sourcefn pipe_ref<'a, Return, Function>(&'a self, f: Function) -> Return where
Function: FnOnce(&'a Self) -> Return,
fn pipe_ref<'a, Return, Function>(&'a self, f: Function) -> Return where
Function: FnOnce(&'a Self) -> Return,
Apply f
to &self
. Read more
sourcefn pipe_mut<'a, Return, Function>(&'a mut self, f: Function) -> Return where
Function: FnOnce(&'a mut Self) -> Return,
fn pipe_mut<'a, Return, Function>(&'a mut self, f: Function) -> Return where
Function: FnOnce(&'a mut Self) -> Return,
Apply f
to &mut self
. Read more
sourcefn pipe_as_ref<'a, Param, Return, Function>(&'a self, f: Function) -> Return where
Self: AsRef<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a Param) -> Return,
fn pipe_as_ref<'a, Param, Return, Function>(&'a self, f: Function) -> Return where
Self: AsRef<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a Param) -> Return,
Apply f
to &self
where f
takes a single parameter of type Param
and Self
implements trait AsRef<Param>
. Read more
sourcefn pipe_as_mut<'a, Param, Return, Function>(&'a mut self, f: Function) -> Return where
Self: AsMut<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a mut Param) -> Return,
fn pipe_as_mut<'a, Param, Return, Function>(&'a mut self, f: Function) -> Return where
Self: AsMut<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a mut Param) -> Return,
Apply f
to &mut self
where f
takes a single parameter of type Param
and Self
implements trait AsMut<Param>
. Read more
sourcefn pipe_deref<'a, Param, Return, Function>(&'a self, f: Function) -> Return where
Self: Deref<Target = Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a Param) -> Return,
fn pipe_deref<'a, Param, Return, Function>(&'a self, f: Function) -> Return where
Self: Deref<Target = Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a Param) -> Return,
Apply f
to &self
where f
takes a single parameter of type Param
and Self
implements trait Deref<Target = Param>
. Read more
sourcefn pipe_deref_mut<'a, Param, Return, Function>(
&'a mut self,
f: Function
) -> Return where
Self: DerefMut<Target = Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a mut Param) -> Return,
fn pipe_deref_mut<'a, Param, Return, Function>(
&'a mut self,
f: Function
) -> Return where
Self: DerefMut<Target = Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a mut Param) -> Return,
Apply f
to &mut self
where f
takes a single parameter of type Param
and Self
implements trait [DerefMut<Target = Param>
]. Read more
sourcefn pipe_borrow<'a, Param, Return, Function>(&'a self, f: Function) -> Return where
Self: Borrow<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a Param) -> Return,
fn pipe_borrow<'a, Param, Return, Function>(&'a self, f: Function) -> Return where
Self: Borrow<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a Param) -> Return,
Apply f
to &self
where f
takes a single parameter of type Param
and Self
implements trait Borrow<Param>
. Read more
sourcefn pipe_borrow_mut<'a, Param, Return, Function>(
&'a mut self,
f: Function
) -> Return where
Self: BorrowMut<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a mut Param) -> Return,
fn pipe_borrow_mut<'a, Param, Return, Function>(
&'a mut self,
f: Function
) -> Return where
Self: BorrowMut<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a mut Param) -> Return,
Apply f
to &mut self
where f
takes a single parameter of type Param
and Self
implements trait BorrowMut<Param>
. Read more
sourceimpl<X> Pipe for X
impl<X> Pipe for X
sourcefn pipe<Return, Function>(self, f: Function) -> Return where
Function: FnOnce(Self) -> Return,
fn pipe<Return, Function>(self, f: Function) -> Return where
Function: FnOnce(Self) -> Return,
Apply f
to self
. Read more
sourcefn pipe_ref<'a, Return, Function>(&'a self, f: Function) -> Return where
Function: FnOnce(&'a Self) -> Return,
fn pipe_ref<'a, Return, Function>(&'a self, f: Function) -> Return where
Function: FnOnce(&'a Self) -> Return,
Apply f
to &self
. Read more
sourcefn pipe_mut<'a, Return, Function>(&'a mut self, f: Function) -> Return where
Function: FnOnce(&'a mut Self) -> Return,
fn pipe_mut<'a, Return, Function>(&'a mut self, f: Function) -> Return where
Function: FnOnce(&'a mut Self) -> Return,
Apply f
to &mut self
. Read more
sourcefn pipe_as_ref<'a, Param, Return, Function>(&'a self, f: Function) -> Return where
Self: AsRef<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a Param) -> Return,
fn pipe_as_ref<'a, Param, Return, Function>(&'a self, f: Function) -> Return where
Self: AsRef<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a Param) -> Return,
Apply f
to &self
where f
takes a single parameter of type Param
and Self
implements trait AsRef<Param>
. Read more
sourcefn pipe_as_mut<'a, Param, Return, Function>(&'a mut self, f: Function) -> Return where
Self: AsMut<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a mut Param) -> Return,
fn pipe_as_mut<'a, Param, Return, Function>(&'a mut self, f: Function) -> Return where
Self: AsMut<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a mut Param) -> Return,
Apply f
to &mut self
where f
takes a single parameter of type Param
and Self
implements trait AsMut<Param>
. Read more
sourcefn pipe_deref<'a, Param, Return, Function>(&'a self, f: Function) -> Return where
Self: Deref<Target = Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a Param) -> Return,
fn pipe_deref<'a, Param, Return, Function>(&'a self, f: Function) -> Return where
Self: Deref<Target = Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a Param) -> Return,
Apply f
to &self
where f
takes a single parameter of type Param
and Self
implements trait Deref<Param>
. Read more
sourcefn pipe_deref_mut<'a, Param, Return, Function>(
&'a mut self,
f: Function
) -> Return where
Self: DerefMut<Target = Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a mut Param) -> Return,
fn pipe_deref_mut<'a, Param, Return, Function>(
&'a mut self,
f: Function
) -> Return where
Self: DerefMut<Target = Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a mut Param) -> Return,
Apply f
to &mut self
where f
takes a single parameter of type Param
and Self
implements trait DerefMut<Param>
. Read more
sourcefn pipe_borrow<'a, Param, Return, Function>(&'a self, f: Function) -> Return where
Self: Borrow<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a Param) -> Return,
fn pipe_borrow<'a, Param, Return, Function>(&'a self, f: Function) -> Return where
Self: Borrow<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a Param) -> Return,
Apply f
to &self
where f
takes a single parameter of type Param
and Self
implements trait Deref<Param>
. Read more
sourcefn pipe_borrow_mut<'a, Param, Return, Function>(
&'a mut self,
f: Function
) -> Return where
Self: BorrowMut<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a mut Param) -> Return,
fn pipe_borrow_mut<'a, Param, Return, Function>(
&'a mut self,
f: Function
) -> Return where
Self: BorrowMut<Param>,
Param: 'a + ?Sized,
Function: FnOnce(&'a mut Param) -> Return,
Apply f
to &mut self
where f
takes a single parameter of type Param
and Self
implements trait DerefMut<Param>
. Read more