oneringbuf 0.7.0

A lock-free single-producer, single-consumer (SPSC) ring buffer with in-place mutability, asynchronous support, and virtual memory optimisation.
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

//! Sync iterators.

use crate::ring_buffer::{OneRB, SharedRB, wrappers::refs::IntoRef};

pub(crate) mod cons_iter;
pub(crate) mod detached;
pub(crate) mod prod_iter;
pub(crate) mod work_iter;

pub(crate) struct Iter<B: IntoRef + OneRB> {
    index: usize,
    cached_avail: usize,
    buffer: B::TargetRef,
}

unsafe impl<B: IntoRef + OneRB + SharedRB> Send for Iter<B> {}

impl<B: IntoRef + OneRB> Iter<B> {
    pub(crate) fn new(value: B::TargetRef) -> Self {
        Self {
            index: 0,
            buffer: value,
            cached_avail: 0,
        }
    }
}