qubit-io 0.3.0

Small stream I/O trait utilities for Rust
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

use qubit_io::{
    CoderProgress,
    CoderStatus,
};

#[test]
fn test_coder_progress_exposes_status_and_counts() {
    let complete = CoderProgress::complete(2, 3);
    assert_eq!(CoderStatus::Complete, complete.status());
    assert_eq!(2, complete.read());
    assert_eq!(3, complete.written());
    assert_eq!(0, complete.required());
    assert_eq!(None, complete.index());
    assert_eq!(0, complete.available());

    let status = CoderStatus::NeedInput {
        input_index: 0,
        required: 0,
        available: 0,
    };
    assert!(matches!(
        CoderProgress::new(status, 1, 1).status(),
        CoderStatus::NeedInput { .. },
    ));
    let status = CoderStatus::NeedInput {
        input_index: 4,
        required: 3,
        available: 1,
    };
    let need_input = CoderProgress::new(status, 1, 2);
    assert_eq!(3, need_input.required());
    assert_eq!(Some(4), need_input.index());
    assert_eq!(1, need_input.available());

    let status = CoderStatus::NeedOutput {
        output_index: 0,
        required: 0,
        available: 0,
    };
    assert!(matches!(
        CoderProgress::new(status, 1, 0).status(),
        CoderStatus::NeedOutput { .. },
    ));
    let status = CoderStatus::NeedOutput {
        output_index: 7,
        required: 8,
        available: 9,
    };
    let need_output = CoderProgress::new(status, 5, 6);
    assert_eq!(8, need_output.required());
    assert_eq!(Some(7), need_output.index());
    assert_eq!(9, need_output.available());
}