hydro2-basic-operators 0.1.0

A collection of fundamental operators for the hydro2 network ecosystem.
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

// ---------------- [ File: src/no_op.rs ]
crate::ix!();

// --------------------------------------
// NoOpOperator<T>
// --------------------------------------
#[derive(NamedItem, Operator, Debug)]
#[operator(
    execute="do_nothing",
    opcode="BasicOpCode::NoOp"
)]
pub struct NoOpOperator
{
    name: String,
}

impl NoOpOperator
{
    pub fn with_name(x: impl AsRef<str>) -> Self {
        Self {
            name: x.as_ref().to_string(),
        }
    }

    async fn do_nothing(&self) -> NetResult<()> {
        info!("NoOpOperator => does nothing");
        Ok(())
    }
}

impl Default for NoOpOperator
{
    fn default() -> Self {
        NoOpOperator::with_name("default")
    }
}

#[cfg(test)]
mod no_op_operator_tests {
    use super::*;

    #[tokio::test]
    async fn test_no_op_operator_basic() -> Result<(), NetworkError> {
        let nop = NoOpOperator::default();
        let input: [Option<&NoOpOperatorIO>;4] = [None,None,None,None];
        let mut out: [Option<NoOpOperatorIO>;4] = [None,None,None,None];

        nop.execute(input, &mut out).await?;
        assert_eq!(out[0], None);
        assert_eq!(nop.name(), "default");
        Ok(())
    }

    #[tokio::test]
    async fn test_no_op_operator_with_name() -> Result<(), NetworkError> {
        let nop = NoOpOperator::with_name("my-noop");
        assert_eq!(nop.name(), "my-noop");
        let input = [None,None,None,None];
        let mut out = [None,None,None,None];
        nop.execute(input, &mut out).await?;
        assert_eq!(out, [None,None,None,None]);
        Ok(())
    }
}