jiq 3.21.0

Interactive JSON query tool with real-time output
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

use std::time::Instant;

const DEBOUNCE_MS: u64 = 150;

#[cfg(test)]
pub const TEST_DEBOUNCE_MS: u64 = DEBOUNCE_MS;

fn system_time_ms() -> u64 {
    use std::sync::OnceLock;
    static START: OnceLock<Instant> = OnceLock::new();
    START.get_or_init(Instant::now).elapsed().as_millis() as u64
}

#[derive(Debug, Default)]
pub struct Debouncer {
    scheduled_at_ms: Option<u64>,
    pending_execution: bool,
}

impl Debouncer {
    pub fn new() -> Self {
        Self::default()
    }

    pub fn schedule_execution(&mut self) {
        self.schedule_execution_at(system_time_ms());
    }

    pub fn schedule_execution_at(&mut self, current_time_ms: u64) {
        self.scheduled_at_ms = Some(current_time_ms);
        self.pending_execution = true;
    }

    pub fn should_execute(&self) -> bool {
        self.should_execute_at(system_time_ms())
    }

    pub fn should_execute_at(&self, current_time_ms: u64) -> bool {
        if !self.pending_execution {
            return false;
        }
        match self.scheduled_at_ms {
            Some(scheduled) => current_time_ms >= scheduled + DEBOUNCE_MS,
            None => false,
        }
    }

    pub fn mark_executed(&mut self) {
        self.pending_execution = false;
        self.scheduled_at_ms = None;
    }

    pub fn has_pending(&self) -> bool {
        self.pending_execution
    }
}

#[cfg(test)]
#[path = "debouncer_tests.rs"]
mod debouncer_tests;