d4 0.3.9

The D4 file format implementation
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

use std::iter::Once;

use super::{SimpleTask, Task, TaskPartition};

pub struct ValueRange(String, u32, u32);

impl SimpleTask for ValueRange {
    fn new(chr: &str, start: u32, end: u32) -> Self {
        Self(chr.to_string(), start, end)
    }
}

pub struct ValueRangePartition {
    min_value: i32,
    max_value: i32,
}

impl TaskPartition<Once<i32>> for ValueRangePartition {
    type ParentType = ValueRange;
    type ResultType = (i32, i32);
    fn new(_left: u32, _right: u32, _: &Self::ParentType) -> Self {
        Self {
            min_value: i32::MAX,
            max_value: i32::MIN,
        }
    }
    #[inline(always)]
    fn feed(&mut self, _: u32, value: &mut Once<i32>) -> bool {
        let value = value.next().unwrap();
        self.min_value = self.min_value.min(value);
        self.max_value = self.max_value.max(value);
        true
    }
    #[inline(always)]
    fn feed_range(&mut self, _: u32, _: u32, value: &mut Once<i32>) -> bool {
        self.feed(0, value)
    }
    fn result(&mut self) -> Self::ResultType {
        (self.min_value, self.max_value)
    }
}

impl Task<Once<i32>> for ValueRange {
    type Partition = ValueRangePartition;
    type Output = (i32, i32);

    fn region(&self) -> (&str, u32, u32) {
        (self.0.as_ref(), self.1, self.2)
    }

    fn combine(&self, parts: &[(i32, i32)]) -> Self::Output {
        let mut ret = (i32::MAX, i32::MIN);
        for &(min, max) in parts {
            ret.0 = ret.0.min(min);
            ret.1 = ret.1.max(max);
        }
        ret
    }
}