swapvec 0.4.2

A Vector swapping to disk after exceeding a given length
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

use swapvec::{SwapVec, SwapVecConfig};

#[test]
fn with_file() {
    let config = SwapVecConfig {
        compression: None,
        swap_after: 16,
        batch_size: 5,
    };

    let vector: Vec<u64> = (0..999).collect();

    let mut v = SwapVec::with_config(config);
    v.consume(vector.clone().into_iter()).unwrap();

    assert!(v.written_to_file());

    let vector_read_back: Vec<u64> = v.into_iter().map(|x| x.unwrap()).collect();

    assert_eq!(vector, vector_read_back);
}

#[test]
fn without_file() {
    let config = SwapVecConfig {
        compression: None,
        swap_after: 1001,
        batch_size: 5,
    };

    let vector: Vec<u64> = (0..999).collect();

    let mut v = SwapVec::with_config(config);
    v.consume(vector.clone().into_iter()).unwrap();

    assert!(!v.written_to_file());

    let vector_read_back: Vec<u64> = v.into_iter().map(|x| x.unwrap()).collect();

    assert_eq!(vector, vector_read_back);
}