dope-manifold 0.36.0

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

use dope_net::{
    link::pool::recv::{delivery, input},
    wire::{self, receive},
};

use crate::app::receive::{
    Batch, GatedScoped, Mode, Owned, Scoped,
    ingress::{self, Strategy},
};

pub(in crate::app::receive::ingress) mod flow;

pub(crate) trait Dispatch<W: wire::Spec>: Mode<W> + Sized {
    /// Statically selected admission and delivery strategy for this mode.
    type Strategy: Strategy<W, Self>;
}

impl<W, I> Dispatch<W> for I
where
    W: wire::Spec,
    I: Batch + input::Mode<W>,
    <I as input::Mode<W>>::Kind: delivery::BorrowedData,
{
    type Strategy = ingress::Batched;
}

impl<W> Dispatch<W> for Scoped
where
    W: wire::Spec,
    Scoped: input::Mode<W>,
    <Scoped as input::Mode<W>>::Kind: delivery::ScopedData + input::Replay<W>,
{
    type Strategy = ingress::Scope;
}

impl<W> Dispatch<W> for GatedScoped
where
    W: wire::Spec,
    GatedScoped: input::Mode<W>,
    <GatedScoped as input::Mode<W>>::Kind: delivery::ScopedData + input::Replay<W>,
{
    type Strategy = ingress::Scope;
}

impl<W, R: Default> Dispatch<W> for Owned<R>
where
    W: input::Execution,
    Owned<R>: input::Mode<W, Kind = input::Retained>,
    <W::Receive as receive::Policy<W>>::Credit: delivery::Ownership<W>,
{
    type Strategy = ingress::Retain;
}