rs-flow 0.5.0

Create flows to execute based in components created and yours connections
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

use std::sync::OnceLock;

use rs_flow::prelude::*;

use super::MyGlobal;

pub struct Message {
    pub message: String,
}

#[async_trait]
impl ComponentRunnable for Message {
    type Global = MyGlobal;
    
    async fn run(&self, ctx: &mut Ctx<Self::Global>) -> Result<Next> {

        ctx.send(self.output("message"), self.message.clone().into());
        Ok(Next::Continue)
    }
}
impl Inputs for Message {
    fn inputs(&self) -> &Ports {
        static INPUTS: OnceLock<Ports> = OnceLock::new();

        INPUTS.get_or_init(|| {
            Ports::new(vec![])
        })
    }
    fn input(&self, _label: &'static str) -> PortId {
        panic!("This component not have a input")
    }
}
impl Outputs for Message {
    fn outputs(&self) -> &Ports {
        static OUTPUTS: OnceLock<Ports> = OnceLock::new();

        OUTPUTS.get_or_init(|| {
            Ports::new(vec![Port::new(0)])
        })
    }
    fn output(&self, label: &'static str) -> PortId {
        if label == "message" {
            return 0;
        } else {
            panic!("Not found output with label = {label}")
        }
    }
}