bondi 0.1.2

Single producer, multi consumer lock-free ring buffer (experimental)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use crate::ring::Ring;
use std::sync::Arc;

#[derive(Debug)]
pub struct Reader<T> {
    ring: Arc<Ring<T>>,
    idx: usize,
}

impl<T: Clone + std::fmt::Debug> Reader<T> {
    pub fn new(ring: Arc<Ring<T>>, idx: usize) -> Self {
        // TODO: signal the Ring that there is a new consumer
        // and accomodate its index right where the slowest consumer is
        Self { ring, idx: idx }
    }

    pub fn read(&self) -> T {
        let result = self.ring.get(self.idx);
        result.clone()
    }
}