sark-core 0.25.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

use crate::decode::state;

/// One route payload retaining its exact execution and completion state.
pub enum Value<F: state::Set> {
    SyncOpen(F::SyncOpen),
    SyncFinished(F::SyncFinished),
    TaskOpen(F::TaskOpen),
    TaskFinished(F::TaskFinished),
    DuplexOpen(F::DuplexOpen),
    DuplexFinished(F::DuplexFinished),
    UnsupportedOpen(F::UnsupportedOpen),
    UnsupportedFinished(F::UnsupportedFinished),
}

/// Terminal operation over route payloads that does not consume route identity.
pub trait Fold<F: state::Set>: Sized {
    type Output;

    fn apply(self, value: Value<F>) -> Self::Output;
}

/// Consuming route dispatch that explicitly discards route identity.
pub trait Flow<F: state::Set>: Sized {
    fn fold<V: Fold<F>>(self, visit: V) -> V::Output;
}