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

//! # Time Operation Nodes
//!
//! This module provides nodes for time-based stream manipulation.
//!
//! ## Standard Port Pattern
//!
//! All time 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
//!
//! - **DelayNode**: Delay items by duration (`configuration`, `in`, `duration` → `out`, `error`)
//! - **TimeoutNode**: Apply timeout to item reception (`configuration`, `in`, `timeout` → `out`, `error`)
//! - **TimerNode**: Generate periodic events (`configuration`, `interval` → `out`, `error`)
//! - **TimestampNode**: Add timestamp to items (`configuration`, `in` → `out`, `error`)
//! - **CurrentTimeNode**: Generate current timestamp (`configuration`, `trigger` → `out`, `error`)
//! - **FormatTimeNode**: Format timestamps into strings (`configuration`, `in`, `format` → `out`, `error`)
//! - **ParseTimeNode**: Parse time strings into timestamps (`configuration`, `in`, `format` → `out`, `error`)

pub mod current_time_node;
#[cfg(test)]
pub mod current_time_node_test;
pub mod delay_node;
#[cfg(test)]
pub mod delay_node_test;
pub mod format_time_node;
#[cfg(test)]
pub mod format_time_node_test;
pub mod parse_time_node;
#[cfg(test)]
pub mod parse_time_node_test;
pub mod timeout_node;
#[cfg(test)]
pub mod timeout_node_test;
pub mod timer_node;
#[cfg(test)]
pub mod timer_node_test;
pub mod timestamp_node;
#[cfg(test)]
pub mod timestamp_node_test;

pub use current_time_node::CurrentTimeNode;
pub use delay_node::DelayNode;
pub use format_time_node::FormatTimeNode;
pub use parse_time_node::ParseTimeNode;
pub use timeout_node::TimeoutNode;
pub use timer_node::TimerNode;
pub use timestamp_node::TimestampNode;