diff --git a/src/rayon.rs b/src/rayon.rs index 1c8e844f..5f265f0e 100644 --- a/src/rayon.rs +++ b/src/rayon.rs @@ -1,7 +1,7 @@ use rayon::iter::plumbing::{Consumer, Folder, Producer, ProducerCallback, UnindexedConsumer}; use rayon::iter::{IndexedParallelIterator, ParallelIterator}; -use crate::{ProgressBar, ProgressBarIter}; +use crate::{iter, ProgressBar, ProgressBarIter}; /// Wraps a Rayon parallel iterator. /// @@ -41,7 +41,11 @@ where impl> ParallelProgressIterator for T { fn progress_with(self, progress: ProgressBar) -> ProgressBarIter { - ProgressBarIter { it: self, progress } + ProgressBarIter { + it: self, + progress, + hold_max: iter::RingBufWrap::new(), + } } } @@ -99,6 +103,7 @@ impl> Producer for ProgressProducer

{ ProgressBarIter { it: self.base.into_iter(), progress: self.progress, + hold_max: iter::RingBufWrap::new(), } }