dope-manifold 0.22.0

Owned application and service composition for dope
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

use data::compose;
use dope_core::driver::route::Identity;
use dope_net::link::egress::{self, data};
use o3::base::cell::region;

use crate::client::{
    conn,
    port::{self, error},
};

pub trait Branches<'d, L, R, ID: Identity> {
    fn try_left(
        &self,
        region: &mut region::Token<region::Identity<'d>>,
        conn: conn::Id<'d, ID>,
        load: egress::NonEmpty<L>,
    ) -> Result<(), error::Unsent<'d, L, ID>>;

    fn try_right(
        &self,
        region: &mut region::Token<region::Identity<'d>>,
        conn: conn::Id<'d, ID>,
        load: egress::NonEmpty<R>,
    ) -> Result<(), error::Unsent<'d, R, ID>>;
}

impl<'e, 'd, L: data::raw::Payload<'d>, R: data::raw::Payload<'d>, ID: Identity>
    Branches<'d, L, R, ID> for port::Port<'e, 'd, compose::Either<L, R>, ID>
{
    fn try_left(
        &self,
        region: &mut region::Token<region::Identity<'d>>,
        conn: conn::Id<'d, ID>,
        load: egress::NonEmpty<L>,
    ) -> Result<(), error::Unsent<'d, L, ID>> {
        self.core
            .try_project(region, conn, load, |queue, region, load| {
                queue.try_left(region, load)
            })
    }

    fn try_right(
        &self,
        region: &mut region::Token<region::Identity<'d>>,
        conn: conn::Id<'d, ID>,
        load: egress::NonEmpty<R>,
    ) -> Result<(), error::Unsent<'d, R, ID>> {
        self.core
            .try_project(region, conn, load, |queue, region, load| {
                queue.try_right(region, load)
            })
    }
}