From c37fa9983068af5c2f5f82323db40b598b94c702 Mon Sep 17 00:00:00 2001 From: djugei Date: Fri, 13 Sep 2024 18:02:23 +0200 Subject: [PATCH] make rayon feature compile --- src/rayon.rs | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) 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(), } }