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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

use crate::connector::StreamDescriptor;
use crate::prelude::BaseTx;
use crate::utils::{HealthFlag, Reducer, StateCell, StateMarker};

#[non_exhaustive]
pub struct HookArgs<'a, Ev, EvTx, R, State, Desc, T>
where
    Ev: Send + 'static,
    EvTx: BaseTx,
    R: Reducer,
    State: StateMarker,
    Desc: StreamDescriptor<T>,
{
    pub raw: Ev,
    pub event_tx: &'a mut EvTx,
    pub reducer: &'a mut R,
    pub state: &'a StateCell<State>,
    pub desc: &'a Desc,
    pub health: &'a HealthFlag,
    _marker: std::marker::PhantomData<T>,
}

impl<'a, Ev, EvTx, R, State, Desc, T> HookArgs<'a, Ev, EvTx, R, State, Desc, T>
where
    Ev: Send + 'static,
    EvTx: BaseTx,
    R: Reducer,
    State: StateMarker,
    Desc: StreamDescriptor<T>,
{
    #[inline]
    pub fn new(
        raw: Ev,
        event_tx: &'a mut EvTx,
        reducer: &'a mut R,
        state: &'a StateCell<State>,
        desc: &'a Desc,
        health: &'a HealthFlag,
    ) -> Self {
        Self {
            raw,
            event_tx,
            reducer,
            state,
            desc,
            health,
            _marker: std::marker::PhantomData,
        }
    }
}

pub trait Hook<Ev, EvTx, R, State, Desc, Res, T>
where
    Ev: Send + 'static,
    EvTx: BaseTx,
    R: Reducer,
    State: StateMarker,
    Desc: StreamDescriptor<T>,
{
    fn call<'a>(&'a mut self, args: HookArgs<'a, Ev, EvTx, R, State, Desc, T>) -> Res;
}

// Любое замыкание вида FnMut(HookArgs...) автоматически становится Hook.
impl<Ev, EvTx, R, State, Desc, Res, F, T> Hook<Ev, EvTx, R, State, Desc, Res, T> for F
where
    Ev: Send + 'static,
    EvTx: BaseTx,
    R: Reducer,
    State: StateMarker,
    Desc: StreamDescriptor<T>,
    for<'a> F: FnMut(HookArgs<'a, Ev, EvTx, R, State, Desc, T>) -> Res,
{
    fn call<'a>(&'a mut self, args: HookArgs<'a, Ev, EvTx, R, State, Desc, T>) -> Res {
        self(args)
    }
}
pub trait IntoHook<Ev, EvTx, R, State, Desc, Res, T>: Send + 'static
where
    Ev: Send + 'static,
    EvTx: BaseTx,
    R: Reducer,
    State: StateMarker,
    Desc: StreamDescriptor<T>,
{
    type Out: Hook<Ev, EvTx, R, State, Desc, Res, T> + Send + 'static;
    fn into_hook(self) -> Self::Out;
}

impl<Ev, EvTx, R, State, Desc, Res, F, T> IntoHook<Ev, EvTx, R, State, Desc, Res, T> for F
where
    Ev: Send + 'static,
    EvTx: BaseTx,
    R: Reducer,
    State: StateMarker,
    Desc: StreamDescriptor<T>,
    F: Hook<Ev, EvTx, R, State, Desc, Res, T> + Send + 'static,
{
    type Out = F;
    fn into_hook(self) -> Self::Out {
        self
    }
}