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

use crate::manifold::{
    self,
    schedule::{Block, Terminal, Turn, data::Settlement},
};

/// Data-only state machine driven inside one resident domain.
pub trait Driver<T> {
    type Key: manifold::raw::Key;
    type Block: Block;
    type Error;

    fn can_continue(&self) -> bool;

    fn turn(&mut self, stream: Self::Key, value: &mut T) -> Result<Turn<Self::Block>, Self::Error>;

    fn settle(
        &mut self,
        stream: Self::Key,
        value: &mut T,
        terminal: Terminal<Self::Error>,
    ) -> Settlement;

    fn remove(&mut self, value: T);
}