o3 0.36.0

shared-nothing primitives
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

use crate::buffer::bytes::window::reserve;

/// An unchanged, bounded prefix of one exclusively borrowed ring.
#[must_use = "commit consumes the selected prefix; dropping it leaves the ring unchanged"]
pub struct Prefix<'a, const N: usize> {
    ring: &'a mut reserve::Ring<N>,
    len: usize,
}

impl<'a, const N: usize> Prefix<'a, N> {
    pub fn new(ring: &'a mut reserve::Ring<N>, max: usize) -> Self {
        let len = ring.len().min(max);
        Self { ring, len }
    }

    pub const fn is_empty(&self) -> bool {
        self.len() == 0
    }

    pub const fn len(&self) -> usize {
        self.len
    }

    pub fn total(&self) -> usize {
        self.ring.len()
    }

    pub fn as_slices(&self) -> (&[u8], &[u8]) {
        self.ring.prefix(self.len)
    }

    pub fn truncate(&mut self, max: usize) {
        self.len = self.len.min(max);
    }

    pub fn commit(self) -> &'a mut reserve::Ring<N> {
        self.ring.consume(self.len);
        self.ring
    }
}

const _: () = {
    assert!(size_of::<Prefix<'static, 17>>() == 2 * size_of::<usize>());
    assert!(size_of::<Option<Prefix<'static, 17>>>() == size_of::<Prefix<'static, 17>>());
};