sark-http 0.28.1

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

use crate::payload::compress::dynamic::{
    Field,
    table::{self, delta},
};

/// Retains the original transaction owner until commit or rollback.
pub struct Commit<T: delta::raw::Source> {
    pub(super) owner: T,
}

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

impl<T: delta::raw::Source> Commit<T> {
    pub fn fields(&self) -> impl DoubleEndedIterator<Item = Field<'_>> {
        self.owner.parts().1.iter().map(|item| item.0)
    }

    pub fn apply(mut self) -> T {
        let (table, pending) = self.owner.parts_mut();
        for item in pending.iter() {
            table::Input {
                table,
                field: item.0,
                digest: item.1,
                size: item.2,
            }
            .insert();
        }
        self.owner
    }

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