exocore-core 0.1.26

Core of Exocore (Distributed applications framework)
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 std::ops::Range;

pub fn are_continuous<'a, I, T: 'a + Ord + Copy + Eq>(iter: I) -> bool
where
    I: Iterator<Item = &'a Range<T>>,
{
    get_gaps(iter).is_empty()
}

pub fn get_gaps<'a, I, T: 'a + Ord + Copy + Eq>(iter: I) -> Vec<Range<T>>
where
    I: Iterator<Item = &'a Range<T>>,
{
    let mut sorted: Vec<&Range<T>> = iter.collect();
    sorted.sort_by(|a, b| a.start.partial_cmp(&b.start).unwrap());

    let mut gaps = Vec::new();
    for i in 1..sorted.len() {
        let left = &sorted[i - 1];
        let right = &sorted[i];
        if left.end != right.start {
            gaps.push(Range {
                start: left.end,
                end: right.start,
            });
        }
    }

    gaps
}

#[cfg(test)]
mod test {
    use super::*;

    #[test]
    fn test_find_gaps() {
        let r1 = 10..20;
        let r2 = 30..40;
        let r3 = 40..50;
        let r4 = 80..100;

        let ranges = [r2, r1, r4, r3];
        let gaps = get_gaps(ranges.iter());
        assert_eq!(gaps, vec![20..30, 50..80]);
        assert!(!are_continuous(ranges.iter()));

        let r5 = 30..40;
        let r6 = 40..50;
        let ranges = [r5, r6];
        assert!(are_continuous(ranges.iter()));
    }
}