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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

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

#[test]
fn from_array() {
    let mut rb = Rb::from([123, 321]);
    let (mut prod, mut cons) = rb.split_ref();

    assert_eq!(prod.capacity().get(), 2);
    assert_eq!(cons.occupied_len(), 2);

    assert_eq!(prod.try_push(444), Err(444));

    assert_eq!(cons.try_pop(), Some(123));
    assert_eq!(cons.try_pop(), Some(321));
    assert_eq!(cons.try_pop(), None);
}

#[cfg(feature = "alloc")]
#[test]
fn new() {
    const CAP: usize = 2;
    let rb = Rb::<Heap<i32>>::new(CAP);
    let (mut prod, mut cons) = rb.split();

    assert_eq!(prod.capacity().get(), CAP);

    assert_eq!(prod.try_push(0), Ok(()));
    assert_eq!(prod.try_push(1), Ok(()));
    assert_eq!(prod.try_push(2), Err(2));

    assert_eq!(cons.try_pop(), Some(0));
    assert_eq!(cons.try_pop(), Some(1));
    assert_eq!(cons.try_pop(), None);
}

#[cfg(feature = "alloc")]
#[test]
fn from_vec() {
    let mut vec = Vec::<i32>::with_capacity(2);
    vec.push(123);
    let rb = Rb::from(vec);
    let (mut prod, mut cons) = rb.split();

    assert_eq!(prod.capacity().get(), 2);
    assert_eq!(cons.occupied_len(), 1);

    assert_eq!(prod.try_push(321), Ok(()));
    assert_eq!(prod.try_push(444), Err(444));

    assert_eq!(cons.try_pop(), Some(123));
    assert_eq!(cons.try_pop(), Some(321));
    assert_eq!(cons.try_pop(), None);
}

#[cfg(feature = "alloc")]
#[test]
fn from_boxed_slice() {
    let boxed_slice = Box::new([123, 321]) as Box<[i32]>;
    let rb = Rb::from(boxed_slice);
    let (mut prod, mut cons) = rb.split();

    assert_eq!(prod.capacity().get(), 2);
    assert_eq!(cons.occupied_len(), 2);

    assert_eq!(prod.try_push(444), Err(444));

    assert_eq!(cons.try_pop(), Some(123));
    assert_eq!(cons.try_pop(), Some(321));
    assert_eq!(cons.try_pop(), None);
}