dope-net 0.40.0

Owned network transports for dope
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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122

use o3::buffer::resident::bound;

use crate::link::egress::{
    self, Charge, Excess, NonEmpty, Rejected,
    data::{self, Bound, compose},
    load,
};

pub(in crate::link::egress) mod charge;
pub(in crate::link::egress) mod empty;
pub(in crate::link::egress) mod nonempty;
pub(in crate::link::egress) mod rejected;

/// One immutable payload paired with the exact charge derived before queue
/// mutation. The owned value cannot change between reservation and commit.
#[derive(Debug)]
pub struct Load<B> {
    value: B,
    charge: Charge,
}

impl<B> Load<B> {
    pub fn new<'d>(value: B) -> Self
    where
        B: data::raw::Payload<'d>,
    {
        let charge = Charge::of(&value);
        Self { value, charge }
    }

    pub const fn charge(&self) -> Charge {
        self.charge
    }

    pub const fn as_inner(&self) -> &B {
        &self.value
    }

    pub fn into_inner(self) -> B {
        self.value
    }

    pub fn try_nonempty(self) -> Result<NonEmpty<B>, egress::Rejected<Self, load::Error>> {
        let Self { value, charge } = self;
        let geometry = match charge.try_geometry() {
            Ok(geometry) => geometry,
            Err(reason) => {
                return Err(Rejected::new(Self::from_parts(value, charge), reason));
            }
        };
        Ok(NonEmpty::new(value, geometry.wire(), geometry.resident()))
    }

    /// Checks the actual owner once and retains its exact resident bound.
    pub fn try_bound<G: bound::Bound>(self) -> Result<Load<Bound<B, G>>, Excess<B>> {
        if let bound::Limit::AtMost(maximum) = G::LIMIT
            && self.charge.resident().is_excess(maximum)
        {
            return Err(Excess {
                load: self,
                maximum,
            });
        }
        let (value, charge) = self.into_parts();
        Ok(Load::from_parts(Bound::from_inner(value), charge))
    }

    /// Selects unrestricted retention without a recoverable admission path.
    pub fn unbounded(self) -> Load<Bound<B, bound::Unbounded>> {
        let (value, charge) = self.into_parts();
        Load::from_parts(Bound::from_inner(value), charge)
    }

    /// Wraps the payload in the left branch without changing its exact charge.
    pub fn into_left<R>(self) -> Load<compose::Either<B, R>> {
        let (value, charge) = self.into_parts();
        Load::from_parts(compose::Either::Left(value), charge)
    }

    /// Wraps the payload in the right branch without changing its exact charge.
    pub fn into_right<L>(self) -> Load<compose::Either<L, B>> {
        let (value, charge) = self.into_parts();
        Load::from_parts(compose::Either::Right(value), charge)
    }

    /// Attaches non-payload metadata without measuring the owner again.
    pub fn tagged<K>(self, tag: K) -> Load<compose::Tagged<B, K>> {
        let (value, charge) = self.into_parts();
        Load::from_parts(compose::Tagged::new(value, tag), charge)
    }

    pub(in crate::link) fn into_parts(self) -> (B, Charge) {
        (self.value, self.charge)
    }

    pub(in crate::link) const fn from_parts(value: B, charge: Charge) -> Self {
        Self { value, charge }
    }
}

impl<B, G> Load<Bound<B, G>> {
    /// Injects the proved payload without changing its resident bound or charge.
    pub fn bound_left<R>(self) -> Load<Bound<compose::Either<B, R>, G>> {
        let (value, charge) = self.into_parts();
        Load::from_parts(
            Bound::from_inner(compose::Either::Left(value.into_inner())),
            charge,
        )
    }
}

impl<L, R> Load<compose::Either<L, R>> {
    pub fn split(self) -> compose::Either<Load<L>, Load<R>> {
        let (value, charge) = self.into_parts();
        match value {
            compose::Either::Left(value) => compose::Either::Left(Load::from_parts(value, charge)),
            compose::Either::Right(value) => {
                compose::Either::Right(Load::from_parts(value, charge))
            }
        }
    }
}