logic-mesh 1.0.0

Control logic engine using event based and reactive blocks written in Rust.
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

use libhaystack::val::Value;

use crate::{
    base::{Status, input::Input},
    tokio_impl::{ReaderImpl, WriterImpl},
};

#[cfg(test)]
pub mod mock;

/// Writes the given values to the given inputs as if they had arrived from
/// connected upstream sources. Each input is marked connected (so the block
/// will treat it as a real input) and the value is pushed through the
/// underlying watch channel — a subsequent `block.read_inputs().await` (or
/// the first `wait_on_inputs` inside the block's `execute()`) will drain
/// every input in one pass, populating their `.val` fields.
#[cfg(test)]
pub(crate) async fn write_block_inputs<V, const N: usize>(
    values: [(&mut dyn Input<Reader = ReaderImpl, Writer = WriterImpl>, V); N],
) where
    V: Into<Value>,
{
    for (input, value) in values {
        if !input.is_connected() {
            input.increment_conn();
        }
        input.writer().send((value.into(), Status::Ok)).unwrap();
    }
}