dagrs 0.8.1

Dagrs follows the concept of Flow-based Programming and is suitable for the execution of multiple tasks with graph-like dependencies. Dagrs has the characteristics of high performance and asynchronous execution. It provides users with a convenient programming interface.
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

//! # Example: auto_node
//! The procedural macro `auto_node` simplifies the implementation of `Node` trait for custom types.
//! It works on structs except [tuple structs](https://doc.rust-lang.org/book/ch05-01-defining-structs.html#using-tuple-structs-without-named-fields-to-create-different-types).

use std::sync::Arc;

use dagrs::{EmptyAction, EnvVar, InChannels, Node, NodeTable, OutChannels, auto_node};

#[auto_node]
struct MyNode {/*Put customized fields here.*/}

#[auto_node]
struct _MyNodeGeneric<'a, T: Send + Sync> {
    /*Put customized fields here.*/
    my_field: Vec<T>,
    my_name: &'a str,
}

#[auto_node]
struct _MyUnitNode;

#[tokio::main]
async fn main() {
    let mut node_table = NodeTable::default();

    let node_name = "auto_node".to_string();

    let mut s = MyNode {
        id: node_table.alloc_id_for(&node_name),
        name: node_name.clone(),
        input_channels: InChannels::default(),
        output_channels: OutChannels::default(),
        action: Box::new(EmptyAction),
    };

    assert_eq!(&s.id(), node_table.get(&node_name).unwrap());
    assert_eq!(&s.name(), &node_name);

    let output = s.run(Arc::new(EnvVar::new(NodeTable::default()))).await;
    match output {
        dagrs::Output::Out(content) => assert!(content.is_none()),
        _ => panic!(),
    }
}