omnimesh 1.0.1

Zero-allocation mesh networking middleware for autonomous robot fleets, edge-AI swarms, and multi-agent systems
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

#[derive(Debug, Clone)]
pub struct RingBuffer<T: Copy, const N: usize> {
    data: [Option<T>; N],
    head: usize,
}

impl<T: Copy, const N: usize> Default for RingBuffer<T, N> {
    fn default() -> Self {
        Self::new()
    }
}

impl<T: Copy, const N: usize> RingBuffer<T, N> {
    pub const fn new() -> Self {
        Self {
            data: [None; N],
            head: 0,
        }
    }

    pub fn insert(&mut self, item: T) {
        self.data[self.head] = Some(item);
        self.head = (self.head + 1) % N;
    }

    pub fn contains<F>(&self, predicate: F) -> bool
    where
        F: Fn(&T) -> bool,
    {
        for item in self.data.iter() {
            if let Some(val) = item
                && predicate(val)
            {
                return true;
            }
        }
        false
    }
}