sark-core 0.29.1

Fiber-free request, route, dispatch, and lifecycle core for Sark
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

use core::convert::Infallible;

use crate::decode::state;

/// Route payload family whose only inhabited states are open sync and task bodies.
pub trait Set:
    state::Set<
        SyncOpen = Self::Body,
        SyncFinished = Infallible,
        TaskOpen = Self::Body,
        TaskFinished = Infallible,
        DuplexOpen = Infallible,
        DuplexFinished = Infallible,
        UnsupportedOpen = Infallible,
        UnsupportedFinished = Infallible,
    >
{
    type Body;
}

/// Borrowed operation over an open buffered body without route identity.
pub trait Each<F: Set>: Sized {
    type Output<'a>;

    fn apply<'a>(self, body: &'a mut F::Body) -> Self::Output<'a>;
}

/// Terminal operation that needs the selected route identity.
pub trait Fold<P, F: Set>: Sized {
    type Output;

    fn sync<S: state::Slot<P>>(self, slot: S, body: F::SyncOpen) -> Self::Output;

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