ringbuf 0.4.8

Lock-free SPSC FIFO ring buffer with direct access to inner data
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

use super::Rb;
use crate::{
    storage::{Array, Slice},
    traits::*,
};
#[cfg(feature = "alloc")]
use alloc::boxed::Box;

#[test]
fn capacity() {
    const CAP: usize = 13;
    let mut rb = Rb::<Array<i32, CAP>>::default();
    let urb = &mut rb as &mut Rb<Slice<i32>>;
    assert_eq!(urb.capacity().get(), CAP);
}

#[test]
fn push_pop() {
    let mut rb = Rb::<Array<i32, 1>>::default();
    let urb = &mut rb as &mut Rb<Slice<i32>>;
    let (mut prod, mut cons) = urb.split_ref();

    assert_eq!(prod.try_push(123), Ok(()));
    assert_eq!(prod.try_push(321), Err(321));
    assert_eq!(cons.try_pop(), Some(123));
    assert_eq!(cons.try_pop(), None);
}

#[cfg(feature = "alloc")]
#[test]
fn split() {
    let rb = Rb::<Array<i32, 1>>::default();
    let urb = Box::new(rb) as Box<Rb<Slice<i32>>>;
    let (mut prod, mut cons) = urb.split();

    assert_eq!(prod.try_push(123), Ok(()));
    assert_eq!(prod.try_push(321), Err(321));
    assert_eq!(cons.try_pop(), Some(123));
    assert_eq!(cons.try_pop(), None);
}