streamweave 0.10.1

Composable, async, stream-first computation in pure 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
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
65
66
67
68

//! # Graph Node Library
//!
//! This module provides a library of reusable nodes for building streaming graphs.
//! All nodes implement the unified `Node` trait and support zero-copy data passing
//! via `Arc<dyn Any + Send + Sync>`.
//!
//! ## Node Categories
//!
//! - **Source Nodes**: Generate data (0 inputs, 1+ outputs)
//! - **Transform Nodes**: Process data (1+ inputs, 1+ outputs)
//! - **Sink Nodes**: Consume data (1+ inputs, 0 outputs)
//! - **Router Nodes**: Route data (1+ inputs, 1+ outputs with routing logic)

pub mod advanced;
pub mod aggregation;
pub mod arithmetic;
pub mod array;
pub mod boolean_logic;
pub mod comparison;
pub mod math;
pub mod object;
pub mod reduction;
pub mod stream;
pub mod string;
pub mod time;
pub mod type_ops;

pub mod common;
pub mod condition_node;
pub mod error_branch_node;
pub mod filter_node;
pub mod for_each_node;
pub mod join_node;
pub mod map_node;
pub mod match_node;
pub mod range_node;
pub mod read_variable_node;
pub mod sync_node;
pub mod variable_node;
pub mod while_loop_node;
pub mod write_variable_node;

#[cfg(test)]
mod condition_node_test;
#[cfg(test)]
mod error_branch_node_test;
#[cfg(test)]
mod filter_node_test;
#[cfg(test)]
mod for_each_node_test;
#[cfg(test)]
mod join_node_test;
#[cfg(test)]
mod map_node_test;
#[cfg(test)]
mod match_node_test;
#[cfg(test)]
mod range_node_test;
#[cfg(test)]
mod read_variable_node_test;
#[cfg(test)]
mod sync_node_test;
#[cfg(test)]
mod variable_node_test;
#[cfg(test)]
mod while_loop_node_test;
#[cfg(test)]
mod write_variable_node_test;