o3 0.33.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

use crate::buffer::{bytes::window::reserve, write::consume::Error};

/// Exact source slices admitted while preserving the ring's terminal state.
#[must_use = "call commit to publish the admitted sources"]
pub struct Append<'a, 'source, const N: usize, const S: usize> {
    ring: &'a mut reserve::Ring<N>,
    slices: [&'source [u8]; S],
}

impl<'a, 'source, const N: usize, const S: usize> Append<'a, 'source, N, S> {
    pub fn try_new(
        ring: &'a mut reserve::Ring<N>,
        slices: [&'source [u8]; S],
        limit: usize,
    ) -> Result<Self, Error> {
        let capacity = ring.buf.len() - if ring.closed { 0 } else { N };
        Error::checked_end(ring.len(), capacity.min(limit), &slices)?;
        Ok(Self { ring, slices })
    }

    pub fn commit(self) {
        let Self { ring, slices } = self;
        for source in slices {
            ring.append(source);
        }
    }
}

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