sark-http 0.28.2

HTTP wire types, semantics, codecs, and ownership invariants for Sark
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

use crate::{
    field::metadata::map::record::Entry,
    payload::compress::dynamic::table::delta::{self},
};

/// Retains the original table and journal through the transaction.
///
///
///
pub struct Draft<T: delta::raw::Source> {
    pub(super) owner: T,
    pub(super) change: delta::Change,
}

const _: () = assert!(size_of::<Draft<delta::Borrow<'_>>>() == 4 * size_of::<usize>());

impl<T: delta::raw::Source> Draft<T> {
    pub fn new(mut owner: T) -> Self {
        let (table, pending) = owner.parts_mut();
        let change = delta::Change::new(table, pending);
        Self { owner, change }
    }

    pub fn query<'a, 'field>(&'a mut self, field: Entry<'field>) -> delta::Query<'a, 'field, T> {
        delta::Query::new(self, field)
    }

    pub fn needle<I: Copy>(
        &self,
        name: &[u8],
        map: impl FnMut(delta::Position) -> Option<I>,
    ) -> Option<I> {
        let (table, pending) = self.owner.parts();
        self.change.needle(table, pending, table.needle(name), map)
    }

    pub fn needle_index(&self, name: &[u8]) -> Option<usize> {
        let (table, pending) = self.owner.parts();
        self.change
            .needle(table, pending, table.needle(name), |position| {
                self.change.relative(pending, position)
            })
    }

    pub fn max_size(&self) -> usize {
        self.owner.parts().0.max_size()
    }

    pub fn finish(self) -> delta::Commit<T> {
        delta::Commit { owner: self.owner }
    }

    pub fn rollback(mut self) -> T {
        self.owner.parts_mut().1.clear();
        self.owner
    }
}