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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

//! # Stream Control and Combination Nodes
//!
//! This module provides nodes for controlling stream flow and combining multiple streams.
//!
//! ## Standard Port Pattern
//!
//! All stream nodes follow the standard port pattern:
//! - **Input Ports:** `configuration` (optional but should exist), plus data input ports
//! - **Output Ports:** Data output ports (`out`, etc.), plus `error`
//!
//! ## Available Nodes
//!
//! ### Stream Control
//! - **TakeNode**: Take first N items (`configuration`, `in`, `count` → `out`, `error`)
//! - **SkipNode**: Skip first N items (`configuration`, `in`, `count` → `out`, `error`)
//! - **LimitNode**: Limit total items (`configuration`, `in`, `limit` → `out`, `error`)
//! - **DropNode**: Discard all items (`configuration`, `in` → `out`, `error`)
//! - **BufferNode**: Buffer items into batches (`configuration`, `in`, `size` → `out`, `error`)
//! - **SampleNode**: Sample items at rate (`configuration`, `in`, `rate` → `out`, `error`)
//!
//! ### Stream Combination
//! - **ZipNode**: Combine multiple streams (`configuration`, `in1`, `in2`, ... → `out`, `error`)
//! - **InterleaveNode**: Interleave multiple streams (`configuration`, `in1`, `in2`, ... → `out`, `error`)
//! - **MergeNode**: Merge multiple streams (`configuration`, `in1`, `in2`, ... → `out`, `error`)

pub mod buffer_node;
#[cfg(test)]
/// Test module for buffer node functionality.
pub mod buffer_node_test;
pub mod debounce_node;
#[cfg(test)]
/// Test module for debounce node functionality.
pub mod debounce_node_test;
pub mod distinct_node;
#[cfg(test)]
/// Test module for distinct node functionality.
pub mod distinct_node_test;
pub mod distinct_until_changed_node;
#[cfg(test)]
/// Test module for distinct until changed node functionality.
pub mod distinct_until_changed_node_test;
pub mod drop_node;
#[cfg(test)]
/// Test module for drop node functionality.
pub mod drop_node_test;
pub mod filter_map_node;
#[cfg(test)]
/// Test module for filter map node functionality.
pub mod filter_map_node_test;
pub mod first_node;
#[cfg(test)]
/// Test module for first node functionality.
pub mod first_node_test;
pub mod interleave_node;
#[cfg(test)]
/// Test module for interleave node functionality.
pub mod interleave_node_test;
pub mod last_node;
#[cfg(test)]
/// Test module for last node functionality.
pub mod last_node_test;
pub mod limit_node;
#[cfg(test)]
pub mod limit_node_test;
pub mod merge_node;
#[cfg(test)]
pub mod merge_node_test;
pub mod sample_node;
#[cfg(test)]
pub mod sample_node_test;
pub mod skip_node;
#[cfg(test)]
pub mod skip_node_test;
pub mod take_node;
#[cfg(test)]
pub mod take_node_test;
pub mod throttle_node;
#[cfg(test)]
/// Test module for throttle node functionality.
pub mod throttle_node_test;
pub mod window_node;
#[cfg(test)]
/// Test module for window node functionality.
pub mod window_node_test;
pub mod zip_node;
#[cfg(test)]
pub mod zip_node_test;

pub use buffer_node::BufferNode;
pub use debounce_node::DebounceNode;
pub use distinct_node::DistinctNode;
pub use distinct_until_changed_node::DistinctUntilChangedNode;
pub use drop_node::DropNode;
pub use filter_map_node::{
  FilterMapConfig, FilterMapConfigWrapper, FilterMapFunction, FilterMapNode, filter_map_config,
};
pub use first_node::FirstNode;
pub use interleave_node::InterleaveNode;
pub use last_node::LastNode;
pub use limit_node::LimitNode;
pub use merge_node::MergeNode;
pub use sample_node::SampleNode;
pub use skip_node::SkipNode;
pub use take_node::TakeNode;
pub use throttle_node::ThrottleNode;
pub use window_node::WindowNode;
pub use zip_node::ZipNode;