titanrt 0.7.0

Typed reactive runtime for real-time systems
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

use crate::control::controller::{Controller, ControllerResult};
use crate::control::inputs::Input;
use crate::model::{BaseModel, ModelEvent};
use crate::utils::{CancelToken, HealthFlag};
use std::ops::ControlFlow;

pub trait Policy<E: ModelEvent, H> {
    fn handle(
        &mut self,
        inp: Input<E>,
        model_health: &HealthFlag,
        output_tx: &mut H,
    ) -> ControlFlow<ControllerResult>;
}

pub struct WithModel<'m, M: BaseModel> {
    pub model: &'m mut M,
    pub cfg: &'m mut M::Config,
    pub cancel: &'m CancelToken,
    pub stop_timeout_secs: u64,
}

impl<'m, M: BaseModel> Policy<M::Event, M::OutputTx> for WithModel<'m, M> {
    #[inline(always)]
    fn handle(
        &mut self,
        inp: Input<M::Event>,
        model_health: &HealthFlag,
        output_tx: &mut M::OutputTx,
    ) -> ControlFlow<ControllerResult> {
        match Controller::<M>::handle_with_model(inp, self, model_health, output_tx) {
            ControlFlow::Continue(()) => ControlFlow::Continue(()),
            ControlFlow::Break(r) => ControlFlow::Break(r),
        }
    }
}

pub struct NoModel<'m, M: BaseModel> {
    pub c: &'m mut M::Config,
}

impl<'m, M: BaseModel> Policy<M::Event, M::OutputTx> for NoModel<'m, M> {
    #[inline(always)]
    fn handle(
        &mut self,
        inp: Input<M::Event>,
        _model_health: &HealthFlag,
        output_tx: &mut M::OutputTx,
    ) -> ControlFlow<ControllerResult> {
        match Controller::<M>::handle_no_model(inp, self.c, output_tx) {
            ControlFlow::Continue(()) => ControlFlow::Continue(()),
            ControlFlow::Break(r) => ControlFlow::Break(r),
        }
    }
}