yao 0.1.4

a fast, tiny, extensiable workflow engine
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

use crate::{TaskState, Vars};

#[derive(Debug, Clone, PartialEq)]
pub enum EventAction {
    Create,
    Next,
    Back,
    Cancel,
    Error,
}

impl std::fmt::Display for EventAction {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            EventAction::Create => f.write_str("create"),
            EventAction::Next => f.write_str("next"),
            EventAction::Back => f.write_str("back"),
            EventAction::Cancel => f.write_str("cancel"),
            EventAction::Error => f.write_str("error"),
        }
    }
}

#[derive(Debug, Clone)]
pub struct EventData {
    pub pid: String,
    pub action: EventAction,
    pub state: TaskState,
    pub vars: Vars,
}

impl std::fmt::Display for EventData {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.write_str(&format!(
            "pid:{}, action:{}, state:{}, vars:{:?}",
            self.pid, self.action, self.state, self.vars
        ))
    }
}

mod hub;
mod message;

pub use hub::{Event, EventHub};
pub use message::{Message, UserData};