sark-core 0.21.0

Fiber-free request, route, dispatch, and lifecycle core 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::decode::state;

#[derive(Debug)]
pub enum Sync {}
#[derive(Debug)]
pub enum Task {}
#[derive(Debug)]
pub enum Duplex {}
#[derive(Debug)]
pub enum Unsupported {}
#[derive(Debug)]
pub enum Mixed {}

/// Application-wide execution shape of selected routes.
pub trait Set {}

impl Set for Sync {}
impl Set for Task {}
impl Set for Duplex {}
impl Set for Unsupported {}
impl Set for Mixed {}

impl Kind for Sync {
    type Open<F: state::Set> = F::SyncOpen;
    type Finished<F: state::Set> = F::SyncFinished;
}

impl Kind for Task {
    type Open<F: state::Set> = F::TaskOpen;
    type Finished<F: state::Set> = F::TaskFinished;
}

impl Kind for Duplex {
    type Open<F: state::Set> = F::DuplexOpen;
    type Finished<F: state::Set> = F::DuplexFinished;
}

impl Kind for Unsupported {
    type Open<F: state::Set> = F::UnsupportedOpen;
    type Finished<F: state::Set> = F::UnsupportedFinished;
}

/// Terminal consumer for a route family proven to have one execution kind.
pub trait Fold<P, F: state::Set, K: Kind>: Sized {
    type Output;

    fn open<S: state::Slot<P>>(self, slot: S, body: K::Open<F>) -> Self::Output;

    fn finished<S: state::Slot<P>>(self, slot: S, body: K::Finished<F>) -> Self::Output;
}

/// Uniform execution selected without a runtime execution tag.
#[doc(hidden)]
pub trait Kind: Set + Sized {
    type Open<F: state::Set>;
    type Finished<F: state::Set>;
}