qubit-progress 0.4.6

Generic progress reporting abstractions for Qubit Rust libraries
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

/*******************************************************************************
 *
 *    Copyright (c) 2025 - 2026 Haixing Hu.
 *
 *    SPDX-License-Identifier: Apache-2.0
 *
 *    Licensed under the Apache License, Version 2.0.
 *
 ******************************************************************************/
//! Integration tests covering elapsed time formatting output.

use std::{
    io::Cursor,
    sync::{
        Arc,
        Mutex,
    },
    time::Duration,
};

use qubit_progress::{
    model::{
        ProgressCounters,
        ProgressEvent,
    },
    reporter::{
        ProgressReporter,
        WriterProgressReporter,
    },
};

fn render_line(elapsed: Duration) -> String {
    let output = Arc::new(Mutex::new(Cursor::new(Vec::new())));
    let reporter = WriterProgressReporter::new(output.clone());
    let event = ProgressEvent::running(
        ProgressCounters::new(Some(3))
            .with_active_count(1)
            .with_completed_count(1),
        elapsed,
    );
    reporter.report(&event);
    let bytes = output
        .lock()
        .unwrap_or_else(std::sync::PoisonError::into_inner)
        .get_ref()
        .clone();
    String::from_utf8(bytes).expect("writer output should be UTF-8")
}

#[test]
fn test_elapsed_format_handles_sub_second_and_seconds() {
    assert!(render_line(Duration::from_millis(0)).contains("elapsed 0ms"));
    assert!(render_line(Duration::from_millis(42)).contains("elapsed 42ms"));
    assert!(render_line(Duration::from_millis(1_500)).contains("elapsed 1.500s"));
}

#[test]
fn test_elapsed_format_handles_minutes_and_hours() {
    assert!(render_line(Duration::from_secs(61)).contains("elapsed 1m 1s"));
    assert!(render_line(Duration::from_secs(3_661)).contains("elapsed 1h 1m 1s"));
}