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

use crate::{
    buffer,
    buffer::{
        segments,
        segments::{Chain, Exact, assembly, chain::edit},
    },
};

pub(in crate::buffer::segments) trait Assemble<T: buffer::raw::Segment>:
    buffer::raw::Assemble<T> + Into<Chain<T>>
{
    fn sequence(&mut self) -> &mut segments::Chain<T, segments::Pool<T>>;

    fn try_append(
        self,
        item: segments::Item<T>,
    ) -> Result<Self, crate::mem::Rejected<(Self, segments::Item<T>), assembly::Error>> {
        let mut chain = self;
        let growth = match edit::Growth::try_new(chain.sequence(), &item) {
            Ok(state) => state,
            Err(error) => {
                return Err(crate::mem::Rejected::new(
                    (chain, item),
                    assembly::Error::Total(error),
                ));
            }
        };
        match growth.assemble(chain.sequence(), item, edit::Back) {
            edit::Assembly::Local => Ok(chain),
            edit::Assembly::Exact {
                item,
                growth,
                cause,
            } => {
                let current = chain.sequence().count();
                Ok(Exact::try_reserve((chain, item, growth, cause), current)?.collect())
            }
        }
    }

    fn try_prepend(
        self,
        item: segments::Item<T>,
    ) -> Result<Self, crate::mem::Rejected<(segments::Item<T>, Self), assembly::Error>> {
        let mut chain = self;
        let growth = match edit::Growth::try_new(chain.sequence(), &item) {
            Ok(state) => state,
            Err(error) => {
                return Err(crate::mem::Rejected::new(
                    (item, chain),
                    assembly::Error::Total(error),
                ));
            }
        };
        match growth.assemble(chain.sequence(), item, edit::Front) {
            edit::Assembly::Local => Ok(chain),
            edit::Assembly::Exact {
                item,
                growth,
                cause,
            } => {
                let current = chain.sequence().count();
                Ok(
                    Exact::try_reserve(edit::Prepend::new((item, chain), growth, cause), current)?
                        .collect(),
                )
            }
        }
    }
}