macrograph 0.0.0

Flow based programming framework for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use futures::Future;
use serde_json::Value;
use std::{
    pin::Pin,
    sync::{Arc, Mutex},
};

use crate::{Engine, ExecOutput, ExecuteContext, Node, NodeSchema};

pub type ExecuteOutput = Option<Arc<ExecOutput>>;
pub type NodeRef = Arc<Node>;
pub type SyncExecuteFn = fn(NodeRef, ExecuteContext) -> ExecuteOutput;
pub type AsyncExecuteFn =
    fn(NodeRef, ExecuteContext) -> Pin<Box<dyn Future<Output = ExecuteOutput> + Send>>;
pub type BuildFn = fn(NodeRef);
pub type FireFn = fn(NodeRef, Value) -> ExecuteOutput;

pub type NodeSchemaRef = Arc<NodeSchema>;
pub type EngineRef = ArcMutex<Engine>;

pub type ArcMutex<T> = Arc<Mutex<T>>;