pub struct ProgressUpdater { /* private fields */ }Implementations§
Source§impl ProgressUpdater
impl ProgressUpdater
pub fn new( progress_sender: Option<UnboundedSender<ProgressUpdate>>, group: Arc<RwLock<RequestGroup>>, atomic_metrics: Arc<AtomicMetrics>, perf_monitor: Option<Arc<PerformanceMonitor>>, ) -> Self
pub fn reset(&mut self, completed_bytes: u64)
pub async fn update_progress( &mut self, completed_bytes: u64, progress_update_threshold: u64, speed_update_interval_ms: u64, )
pub fn last_progress_update(&self) -> u64
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for ProgressUpdater
impl !UnwindSafe for ProgressUpdater
impl Freeze for ProgressUpdater
impl Send for ProgressUpdater
impl Sync for ProgressUpdater
impl Unpin for ProgressUpdater
impl UnsafeUnpin for ProgressUpdater
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more